From 4ca27aec303f54dc9ee670c67c2fefa80dd004a1 Mon Sep 17 00:00:00 2001
From: SangTran-127 <tranquangsang12.7@gmail.com>
Date: Sun, 9 Aug 2026 18:32:44 +0700
Subject: feat: add KeyByOperator and wordCounter for stateful processing

---
 core/operator.go | 13 -------------
 1 file changed, 13 deletions(-)
 delete mode 100644 core/operator.go

(limited to 'core/operator.go')

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
-}
-- 
cgit v1.2.3