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