0
我有查询和执行计划,我想利用该快照这样我就可以在接收端恢复并重新开始执行它。了解神功快照概念
- 什么格式应该发送到接收器?
- 如何在接收端恢复?
以下是一些代码,我从西提仓库取。
SiddhiManager siddhiManager = new SiddhiManager();
String query =
"define stream inStream(meta_roomNumber int,meta_temperature double);" +
"from inStream#window(10)[meta_temperature > 50]\n" +
"select *" +
"insert into outStream;";
ExecutionPlanRuntime executionPlanRuntime = siddhiManager.createExecutionPlanRuntime(query);
executionPlanRuntime.start();
SiddhiContext siddhicontext = new SiddhiContext();
context.setSiddhiContext(siddhicontext);
context.setSnapshotService(new SnapshotService(context));
executionPlanRuntime.snapshot();
上面提到的方式在本地机器上正常工作。我有过,我现在用的插座做网络发送快照并使其在分布式环境中工作。 –