1 files changed, 1 insertions, 3 deletions
diff --git a/main.go b/main.go
index 2399ceb..f829de6 100644
--- a/main.go
+++ b/main.go
@@ -86,9 +86,7 @@ func main() {
        ch3 := make(chan core.StreamRecord[Transaction], len(txList))
        ch4 := make(chan core.StreamRecord[string], len(txList))
-        wo := operator.NewWatermarkGeneratorOperator[Transaction](0, func(in Transaction) int64 {
+        wo := operator.NewWatermarkGeneratorOperator[Transaction](0)
-                return in.Timestamp
-        })
        ko := operator.NewKeyByOperator[Transaction](func(in Transaction) string {
                return in.User

diff --git a/main.go b/main.go index 2399ceb..f829de6 100644 --- a/main.go +++ b/main.go
@@ -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