...
Code Block |
---|
#CREATE_KV_STORE test MemoryStore(createOnlyIfNotExists=false) /// default is true |
Access a store
Currently, only MEP functions can be used to read an write from the store. So this can be used in all operators that contain expressions or predicates (e.g. Map operator or Select operator)
...
Code Block |
---|
#PARSER PQL
#RUNQUERY
timer = TIMER({
period = 1000,
source = 'timersource'
}
)
Map1 = MAP({EXPRESSIONS = ['time','kvwrite("test2","Time",time)','kvread("test2", "Time")']}, timer) |
You could also use an operator to write to an existing store:
StoreWriter
Code Block |
---|
#PARSER PQL #RUNQUERY timer = TIMER({ period = 1000, source = 'timersource' } ) out = StoreWriter({IdAttribute='time', store="test2")},timer) |