infosphere-spl - 我们如何在 IBM InfoSphere Streams 的 Custom() Operator 的 onTuple 上处理两个不同的输入流？

Question

在自定义运算符中，我试图打开一个在启动时提交的文件，并对文件中的值进行标记，并将这些值与其他文件的输入流进行比较。

Answer 1

您可以在自定义运算符的逻辑中有多个 onTuple 子句。

这是一个例子。在这里，我们有两个输入端口 Beacon_1_out0 和 Beacon_2_out0。我为每个输入端口添加了 onTuple 子句，并对来自每个输入端口的数据进行处理。每个端口的处理都是独立进行的。

() as Custom_3 = Custom(Beacon_1_out0 ; Beacon_2_out0)
        {
            logic 

            onTuple Beacon_1_out0:
            {
                printStringLn((rstring)Beacon_1_out0);
            }

            onTuple Beacon_2_out0:
            {
                printStringLn((rstring)Beacon_1_out0);
            }
        }

如果您要比较来自多个流的数据，您可能需要使用 Join 运算符。Join 运算符应该允许您更轻松地比较来自多个输入流的数据。