esper - 有人能解释一下在 Esper 中使用什么数据流吗？

Question

我在 esper 文档中阅读了有关数据流的信息，但不明白应该在应用程序的哪个位置使用它。

  create dataflow HelloWorldDataFlow
  BeaconSource -> helloworld.stream { text: 'hello world' , iterations: 1}
  LogSink(helloworld.stream) {}

当我运行上面的代码时，当我使用 EPDataFlowINstance .run() 流时没有任何反应

Answer 1

也许日志配置不正确。文档中有一些关于 log4j 配置的信息。

根据我的经验，数据流并不是那么重要，因为输入和输出通常已经给出并且不需要是声明性的。使用数据流，它可以从较低级别的事实中获得很小的性能提升。