goflink.git/core, branch main goflink http://git.sangtran.io.vn/goflink.git/atom?h=main 2026-08-13T16:42:53+00:00 feat: add on timer & watermark 2026-08-13T16:42:53+00:00 SangTran-127 tranquangsang12.7@gmail.com 2026-08-13T16:42:53+00:00 urn:sha1:91b1c642601efbbcc5af9931e087f68b2c72fc3d 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 feat: implement memory state backend with key group assignment and value state interface 2026-08-08T18:11:31+00:00 SangTran-127 tranquangsang12.7@gmail.com 2026-08-08T18:11:31+00:00 urn:sha1:4d62f01af159fddd56585b3dce19b8a0f47369c1 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 initialize goflink module with core stream record implementation 2026-08-08T04:31:29+00:00 SangTran-127 tranquangsang12.7@gmail.com 2026-08-08T04:31:29+00:00 urn:sha1:77a3b3e86b06504bdf37e35d83a192806a95a63e