 ngjaying
|
7a26bf9675
test(checkpoint): refactor test
|
преди 4 години |
|
ngjaying
|
2894141c7f
refactor(checkpoint): do not add internal api to StreamContext
|
преди 4 години |
|
ngjaying
|
6b72931ada
feat(checkpoint): support window state
|
преди 4 години |
|
ngjaying
|
2ab6230690
test(stream): clean up checkpoins and sink cached after each run
|
преди 4 години |
|
ngjaying
|
5165eb99bf
refactor(util): get data loc return the test location for testing
|
преди 4 години |
|
ngjaying
|
d3298cb225
feat(checkpoint): checkpoint controllers
|
преди 4 години |
|
ngjaying
|
0d3c5a14a0
feat(state): support function state
|
преди 4 години |
|
ngjaying
|
f3eb4a60c0
feat(state): support memory state in source/sink
|
преди 4 години |
|
ngjaying
|
a549ad75b3
feat(plugin): update extension test for embeded functions
|
преди 5 години |
|
ngjaying
|
eafa98bde7
feat(test): extension test cannot run in windows
|
преди 5 години |
|
ngjaying
|
9e5ee5db2c
refactor(processor): refactor stream processor to not store the statement string as state. Instead, make it a parameter for ExecStmt
|
преди 5 години |
|
ngjaying
|
1674c039b2
refactor(all): format by go fmt
|
преди 5 години |
|
ngjaying
|
14b97431f7
bug(test): fix processor test
|
преди 5 години |
|
ngjaying
|
835e3bfd63
bug(extension): agg function does not called successfully
|
преди 5 години |
 RockyJin
|
5762b09dbf
fix go module issue
|
преди 5 години |
|
ngjaying
|
efa609ca41
refactor(kv): rename all badger occurrences
|
преди 5 години |
|
ngjaying
|
f9044cc072
feat(extension): support aggregate function, tests and refactors
|
преди 5 години |
