Skip to content

Commit

Permalink
add comment
Browse files Browse the repository at this point in the history
Signed-off-by: jyu6 <[email protected]>
  • Loading branch information
jyu6 committed Feb 2, 2023
1 parent d253692 commit 2f3797d
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion pkg/watermark/ot/ot.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,10 @@ import (
type Value struct {
Offset int64
Watermark int64
Idle bool
// Idle is set to true if the given processor entity hasn't published anything
// to the offset timeline bucket in a batch processing cycle.
// Idle is used to signal an idle watermark.
Idle bool
}

// EncodeToBytes encodes a Value object into byte array.
Expand Down

0 comments on commit 2f3797d

Please sign in to comment.