| .. |
|
checkpoint
|
76619d8620
feat(*): add copyright statement in batch
|
3 anni fa |
|
collector
|
76619d8620
feat(*): add copyright statement in batch
|
3 anni fa |
|
connection
|
75888e1a66
fix(auth): fix cert auth bug in mqtt and http
|
3 anni fa |
|
context
|
931fdebb9f
feat(topo): add context function to get the transformed data
|
3 anni fa |
|
memory
|
68d8cd9bd1
feat(memory): memory source data to include the topic in metadata
|
3 anni fa |
|
node
|
b593a495d9
feat(planner): merge preprocessor into source node
|
3 anni fa |
|
operator
|
30b5136d8c
refactor(valuer): avoid dynamic case cast when valuing message
|
3 anni fa |
|
planner
|
815c86ff06
fix(planner): add validation for stream name of field ref (#1072)
|
3 anni fa |
|
sink
|
8d5c4c32fe
refactor(edgex): edgex sink to deal with map directly
|
3 anni fa |
|
source
|
b317bcc0b5
refactor(*): avoid using strings.lowercase
|
3 anni fa |
|
state
|
77de2be6bd
feat(store): refactor and doc update
|
3 anni fa |
|
topotest
|
b593a495d9
feat(planner): merge preprocessor into source node
|
3 anni fa |
|
transform
|
931fdebb9f
feat(topo): add context function to get the transformed data
|
3 anni fa |
|
topo.go
|
1925d935bf
fix,refactor(sqlite) https://github.com/lf-edge/ekuiper/issues/842 fix and refactoring
|
3 anni fa |
Jiyong Huang
68d8cd9bd1
feat(memory): memory source data to include the topic in metadata