goflink.git/core/operator.go, branch main goflink http://git.sangtran.io.vn/goflink.git/atom?h=main 2026-08-09T11:32:44+00:00 feat: add KeyByOperator and wordCounter for stateful processing 2026-08-09T11:32:44+00:00 SangTran-127 tranquangsang12.7@gmail.com 2026-08-09T11:32:44+00:00 urn:sha1:4ca27aec303f54dc9ee670c67c2fefa80dd004a1 refactor: add context support to transport operators and runtime task management 2026-08-08T10:24:01+00:00 SangTran-127 tranquangsang12.7@gmail.com 2026-08-08T10:24:01+00:00 urn:sha1:0958e46c3651f2c8b6d76bcffbd8820063647d59 implement core transport and processing operators with receiver, emitter, filter, and map functionalities 2026-08-08T05:54:43+00:00 SangTran-127 tranquangsang12.7@gmail.com 2026-08-08T05:54:43+00:00 urn:sha1:acc0b6fbaace61a3befd7f726f9d80fb69391126