问在Apache Apex中，是否可以在DAG中间使用输入运算符

EN

这是一个有趣的用例。您应该能够扩展输入操作符(比如JdbcInputOperator，因为您希望从数据库中读取数据)并向其添加输入端口。此输入端口从您的DAG中的另一个操作符接收数据(元组)，并更新JdbcInputOperator的"where“子句，以便读取基于该子句的数据。希望这就是你要找的。

是的，这是可能的。您可以扩展现有的InputOperator并向其添加InputPort。在这种情况下，Apex平台将把您的运算符作为通用运算符处理，而不调用InputOperator.emitTuples()。调用super.emitTuples()或直接在输出端口上发出将是您的扩展操作员职责。

不能，在DAG之间不能使用输入操作符。正如您已经指出的，由于没有输入流，您将无法从以前的运算符获取数据，以便与此运算符一起使用。

对于您所指出的示例，最好编写自己的带有输入流的泛型操作符，该输入流实际上具有与输入操作符相似的功能，其中它可以基于输入流中的数据从外部源读取数据。

另外，只需要注意一点:如果查询太繁重，最好使用异步线程来查询数据库。此线程可以将数据写入队列，主线程可以从队列中读取记录并在输出流中发出它们。这将确保主运算符线程不会被阻塞，并且运算符不会失败。