Open pranjal0811 opened 5 years ago
Hi,
Is it possible to define tables in Flink siddhi wrapper?
like I have the query like - "define table test_table(name string,id string)" with the provided cep context. I can define stream like cep.registerStream(streamId, stream,fields).
Any suggestions would be appreciated.
Thanks
Hi,
Is it possible to define tables in Flink siddhi wrapper?
like I have the query like - "define table test_table(name string,id string)" with the provided cep context. I can define stream like cep.registerStream(streamId, stream,fields).
Any suggestions would be appreciated.
Thanks