diff options
| author | SangTran-127 <tranquangsang12.7@gmail.com> | 2026-08-09 18:32:44 +0700 |
|---|---|---|
| committer | SangTran-127 <tranquangsang12.7@gmail.com> | 2026-08-09 18:32:44 +0700 |
| commit | 4ca27aec303f54dc9ee670c67c2fefa80dd004a1 (patch) | |
| tree | 5628714f47e374bfb98c1cea99970b19892e8b3e /core/operator.go | |
| parent | a892cb5b1d121177881fa56a79abbafef5880a80 (diff) | |
| download | goflink-4ca27aec303f54dc9ee670c67c2fefa80dd004a1.tar.gz goflink-4ca27aec303f54dc9ee670c67c2fefa80dd004a1.zip | |
feat: add KeyByOperator and wordCounter for stateful processing
Diffstat (limited to 'core/operator.go')
| -rw-r--r-- | core/operator.go | 13 |
1 files changed, 0 insertions, 13 deletions
diff --git a/core/operator.go b/core/operator.go deleted file mode 100644 index 7785d44..0000000 --- a/core/operator.go +++ /dev/null @@ -1,13 +0,0 @@ -package core - -import "context" - -type Emitter[OUT any] interface { - Emit(ctx context.Context, record StreamRecord[OUT]) error -} - -type Operator[IN, OUT any] interface { - Open(ctx context.Context) error - Process(ctx context.Context, record StreamRecord[IN], out Emitter[OUT]) error - Close(ctx context.Context) error -} |