将输入运算符动态添加到正在运行的 Apache Apex 应用程序
Posted
技术标签:
【中文标题】将输入运算符动态添加到正在运行的 Apache Apex 应用程序【英文标题】:Adding Input Operator Dynamically to a running Apache Apex application 【发布时间】:2017-04-13 07:27:29 【问题描述】:是否可以在运行的 Apex 应用程序中为不同的源添加输入运算符? 例如:在生产环境中,我正在运行 Apex 应用程序以从输入源读取文本文件,并且我想将 Kafka 源及其输入运算符添加到同一个 DAG。
【问题讨论】:
【参考方案1】:普里扬舒, 您可以有多个输入运算符。只需将 kafka 输入运算符添加到您的 dag。
http://docs.datatorrent.com/library_operators/
阿莫尔
【讨论】:
以上是关于将输入运算符动态添加到正在运行的 Apache Apex 应用程序的主要内容,如果未能解决你的问题,请参考以下文章