 discord9
|
93fcb7454c
|
chore: after rebase
|
2024-05-10 15:11:17 +08:00 |
|
|
discord9
|
cfe28b6974
|
chore: debug log
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
9ec6107988
|
refactor: remove unused imports
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
e840bb469d
|
chore: refactor& remove TODOs
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
684850f451
|
fix: get true QueryContext& dedup code
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
76aadb2223
|
chore: cleanup debug log&fix after rebase
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
f360b2e812
|
tests: fix tests
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
138a2aba7f
|
fix: allow empty expire when
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
8f6462c0b0
|
feat: parse expire when
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
46d0b3cd64
|
fix: table name trying best to get full name
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
a17a7f4e47
|
feat: working poc demo...ish
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
50335dd53c
|
write back seems didn't work
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
abaf881f06
|
refactor: tableName as array
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
e1a8215394
|
tests(WIP): get demo working
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
d7942a1a00
|
fix: make worker handle async
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
a6727e2e8d
|
refactor: use table name for sink table
|
2024-05-10 14:52:22 +08:00 |
|
|
discord9
|
d5bdbedcd6
|
refactor: rwlock for frontend invoker&async lock
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
878737f781
|
feat: integrate flow to standalone(untested)
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
d88cff6f51
|
feat: impl Flownode for FlowNodeManager
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
e7801abd0c
|
feat(WIP): simple parser
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
d7a132a02f
|
chore: remove some TODO done
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
a3417f50cf
|
refactor: rename some task to flow
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
099f414f63
|
chore: rename some task to flow
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
c22185abce
|
refactor: make worker sync only and separate thread&test
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
e33afa53f4
|
feat: grpc trait&Server trait
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
7eaf471808
|
feat(WIP): main loop
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
acba753500
|
chore: remove unused
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
5736373820
|
feat impl grpc server
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
74dee25688
|
feat: new() for FlowNodeManager
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
edcbc89c38
|
feat: gen write back req
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
e88a40b58b
|
refactor: use seperate Worker
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
c7647759be
|
feat(WIP): FlowWorker: !Send
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
d8a191a2db
|
refactor: FlowNodeContext
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
ea40691c71
|
chore: some unfinished tests
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
640674b9bc
|
feat: get table schema
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
3fb3fb18c2
|
tests: add one for Send
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
1067d3453d
|
feat: dataflow adapter
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
57e3912aca
|
feat(WIP): FlowNodeManager
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
ebcfb0f1d7
|
feat: now types of errors
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
6442c96847
|
feat: render src/sink
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
b19febc97c
|
feat: sql_to_flow_plan
|
2024-05-10 14:51:44 +08:00 |
|
|
discord9
|
8240a1ace1
|
feat: find all used collection
|
2024-05-10 14:51:44 +08:00 |
|
 Weny Xu
|
89dbf6ddd2
|
chore: bump proto to 219b24 (#3899)
chore: bump to 219b24
|
2024-05-10 03:55:34 +00:00 |
|
 Ruihang Xia
|
66aa08d815
|
fix: memory leak in unit test of telemetry (#3897)
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
|
2024-05-09 14:29:22 +00:00 |
|
|
Weny Xu
|
b8a325d18c
|
feat: implement CacheContainer & TableFlownodeSetCache (#3885)
* feat: implement the `CacheContainer`
* feat: implement the `TableFlownodeSetCache`
* chore: remove unused feature
* chore: remove unused `Arc`
* refactor: refactor origin `get` to `get_by_ref`
* chore: update comments
* refactor: refactor `CacheContainer`
* chore: move `CacheContainer` to container.rs
* feat: add metrics
* chore: update tests
* test: add tests for value not exists
* test: add test for get
* chore: apply suggestions from CR
|
2024-05-09 09:26:35 +00:00 |
|
|
Ruihang Xia
|
ed95e99556
|
chore: deprecate nyc-taxi benchmark (#3891)
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
|
2024-05-09 08:59:38 +00:00 |
|
|
Weny Xu
|
5545a8b023
|
feat: implement drop flow procedure (#3877)
* feat: implement `destroy_flow_metadata` method
* chore: bump proto to 65c1364
* feat: implement the drop flow procedure
* feat: add `MockFlownodeManager`
* tests: add tests for create flow & drop flow procedure
* chore: apply suggestions from CR
* chore: use `ClusterId`
|
2024-05-09 08:23:19 +00:00 |
|
|
Weny Xu
|
5140d247e3
|
feat: implement drop flow parser (#3888)
* feat: implement drop flow parser
* Update src/sql/src/parsers/drop_parser.rs
Co-authored-by: Ruihang Xia <waynestxia@gmail.com>
* fix: fmt code
---------
Co-authored-by: Ruihang Xia <waynestxia@gmail.com>
|
2024-05-09 07:14:22 +00:00 |
|
 Jeremyhi
|
f995f6099f
|
chore: avoid double future (#3890)
|
2024-05-09 07:11:22 +00:00 |
|
|
Jeremyhi
|
7de62ef5d0
|
feat: add metasrv start time to node info (#3883)
|
2024-05-09 06:53:55 +00:00 |
|