diff options
| author | sangtran <tranquangsang12.7@gmail.com> | 2026-09-12 16:35:06 +0700 |
|---|---|---|
| committer | sangtran <tranquangsang12.7@gmail.com> | 2026-09-12 16:35:06 +0700 |
| commit | 50139c994e539f2f902fc0c06ab29ee93c1bc03c (patch) | |
| tree | 7e355de76444c4eb02a178018dcc4d7ab258c466 /main.go | |
| parent | a7cb942d8b03e325b70ac95238d24939939a4c5a (diff) | |
| signature | Verified sangtran <tranquangsang12.7@gmail.com> Key: 8DD79823D235E1BB ultimate trust | |
| download | flux-50139c994e539f2f902fc0c06ab29ee93c1bc03c.tar.gz flux-50139c994e539f2f902fc0c06ab29ee93c1bc03c.zip | |
Diffstat (limited to 'main.go')
| -rw-r--r-- | main.go | 4 |
1 files changed, 1 insertions, 3 deletions
| @@ -86,9 +86,7 @@ func main() { | |||
| 86 | ch3 := make(chan core.StreamRecord[Transaction], len(txList)) | 86 | ch3 := make(chan core.StreamRecord[Transaction], len(txList)) |
| 87 | ch4 := make(chan core.StreamRecord[string], len(txList)) | 87 | ch4 := make(chan core.StreamRecord[string], len(txList)) |
| 88 | 88 | ||
| 89 | wo := operator.NewWatermarkGeneratorOperator[Transaction](0, func(in Transaction) int64 { | 89 | wo := operator.NewWatermarkGeneratorOperator[Transaction](0) |
| 90 | return in.Timestamp | ||
| 91 | }) | ||
| 92 | 90 | ||
| 93 | ko := operator.NewKeyByOperator[Transaction](func(in Transaction) string { | 91 | ko := operator.NewKeyByOperator[Transaction](func(in Transaction) string { |
| 94 | return in.User | 92 | return in.User |