From 50139c994e539f2f902fc0c06ab29ee93c1bc03c Mon Sep 17 00:00:00 2001 From: sangtran Date: Sat, 12 Sep 2026 16:35:06 +0700 Subject: refactor(event-time): make source timestamps authoritative --- main.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) (limited to 'main.go') 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 { - return in.Timestamp - }) + wo := operator.NewWatermarkGeneratorOperator[Transaction](0) ko := operator.NewKeyByOperator[Transaction](func(in Transaction) string { return in.User -- cgit v1.3.1