 Weny Xu
|
030f1e48ab
|
refactor: rename PartitionExprVersion (#309)
Signed-off-by: WenyXu <wenymedia@gmail.com>
|
2026-02-10 17:16:46 +08:00 |
|
|
Weny Xu
|
b9452e3411
|
feat: introduce partition_rule_version (#306)
* feat: introduce `partition_rule_version`
Signed-off-by: WenyXu <wenymedia@gmail.com>
* feat: introduce `partition_rule_version`
Signed-off-by: WenyXu <wenymedia@gmail.com>
* feat: introduce PartitionRuleVersion
Signed-off-by: WenyXu <wenymedia@gmail.com>
* chore: apply suggestions
Signed-off-by: WenyXu <wenymedia@gmail.com>
---------
Signed-off-by: WenyXu <wenymedia@gmail.com>
|
2026-02-06 19:34:18 +08:00 |
|
|
discord9
|
66eb089afa
|
feat: flow add eval interval (#273)
* feat: create flow eval interval
Signed-off-by: discord9 <discord9@163.com>
* fix: eval interval
Signed-off-by: discord9 <discord9@163.com>
* chore: make all
Signed-off-by: discord9 <discord9@163.com>
* fix: flow create request
Signed-off-by: discord9 <discord9@163.com>
* chore: make all
Signed-off-by: discord9 <discord9@163.com>
* chore: fmt
Signed-off-by: discord9 <discord9@163.com>
---------
Signed-off-by: discord9 <discord9@163.com>
|
2025-08-27 16:21:27 +08:00 |
|
|
discord9
|
1797152367
|
feat(flow): bulk notify (#243)
* feat: mark dirty time window
* fix: time window range
* update DirtyWindowRequest
---------
Co-authored-by: Lei, HUANG <mrsatangel@gmail.com>
|
2025-06-16 14:16:14 +08:00 |
|
|
discord9
|
e1070ad3e7
|
feat: flow replace option (#198)
* feat: flow replace
* chore: make
* refactor: rename
* chore: make all
* refactor: more rename
* chore: make all
|
2024-11-14 14:45:09 +08:00 |
|
|
jeremyhi
|
157cfdb527
|
feat: heartbeat extension field (#190)
* feat: heartbeat extemsion field
* feat: extension to extensions
|
2024-09-06 16:09:14 +08:00 |
|
|
discord9
|
7ca323090b
|
feat: flush flow request (#182)
* feat: flush flow
* chore: make all
* chore: newline
|
2024-07-22 14:35:19 +08:00 |
|
|
Ruihang Xia
|
31dd060fc3
|
feat: change EXPIRE WHEN to EXPIRE AFTER (#170)
* feat: change EXPIRE WHEN to EXPIRE AFTER
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
* change expire_after type
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
* optional expire after
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
|
2024-05-27 14:40:56 +08:00 |
|
|
Weny Xu
|
219b2409bb
|
feat: add flow_id and drop_if_exists to DropFlowExpr (#164)
* feat: add `flow_id` and `drop_if_exists` to `DropFlowExpr`
* chore: apply suggestions from CR
* chore: generate code
|
2024-05-10 11:32:37 +08:00 |
|
|
Weny Xu
|
e152fcbf17
|
feat: add QueryContext to DdlTaskRequest and FlowRequestHeader (#166)
|
2024-05-09 14:27:41 +08:00 |
|
|
Weny Xu
|
b5412f7225
|
refactor: remove task suffix (#162)
* refactor: remove task suffix
* chore: rename task_options to flow_options
|
2024-04-29 21:22:55 +08:00 |
|
|
Weny Xu
|
2c14c6e22d
|
refactor: replace sink_table_id with sink_table_name (#153)
|
2024-04-26 16:47:57 +08:00 |
|
|
Weny Xu
|
93ebc1ba90
|
feat: add source_tables and source_table_ids (#151)
* feat: add `source_tables`
* feat: use `SchemaScopedTableName`
* chore: include flow proto
* chore: rename
* feat: add `CreateFlowTask` and `DropFlowTask`
|
2024-04-25 17:29:14 +08:00 |
|
|
discord9
|
5d7db484ce
|
feat: add Create/Remove Task request (#150)
* feat: add Create/Remove Task request
* chore: all supported impls
* feat: flow.server.proto
* feat: add affected task ids
* chore: make all
* chore: typo
* refactor: use u32 for `TaskId`
|
2024-04-25 14:19:55 +08:00 |
|