Может кто-нибудь объяснить, к чему привыкли потоки данных в Esper?

Я прочитал о потоках данных в документации esper и не понимаю, где в приложении его следует использовать.

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

Когда я запускаю код выше, ничего не происходит, когда я.run() поток с использованием EPDataFlowINstance

1 ответ

Возможно, журнал не настроен правильно. В документации есть некоторая информация о конфигурации log4j.

По моему опыту потоки данных не так важны, потому что ввод и вывод часто уже даны и не должны быть декларативными. С потоками данных он может получить небольшой выигрыш в производительности от того, что его более низкий уровень.

Другие вопросы по тегам