如何在级联中仅从一行中获取某些列

Question

假设我有一个管道正在传送一个如下所示的元组：

[K1, V1, V2, V3]

其中每个由制表符分隔。假设我只想提取倒数第​​一列和倒数第二列（V2 列）。我将如何使用 Each 管道来实现这一目标？

[K1, V1, V2, V3]  -> Each pipe -> [K1, V2]

Answer 1

您可以使用 Retain 管道并传递要保留的字段。

你的例子看起来像

[K1, V1, V2, V3]  -> Retain pipe -> [K1, V2]

Answer 2

pipe = new Each( pipe, new Fields( "K1","V2" ), new Identity(), Fields.RESULTS );