2

是否可以在正在运行的 Apex 应用程序中为不同的源添加输入运算符?例如:在生产环境中,我正在运行 Apex 应用程序以从输入源读取文本文件,并且我想将 Kafka 源及其输入运算符添加到同一个 DAG。

4

1 回答 1

3

Priyanshu,您可以有多个输入运算符。只需将 kafka 输入运算符添加到您的 dag。

http://docs.datatorrent.com/library_operators/

阿莫尔

于 2017-04-14T00:25:02.507 回答