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

bwntbbo3  于 2021-06-02  发布在  Hadoop
关注(0)|答案(2)|浏览(390)

假设我有一个管道,它带来了一个元组,看起来像这样: [K1, V1, V2, V3] 其中每一个都由制表符分隔。假设我只想提取最后的第一列和第二列(v2列)。我将如何使用每个管道来实现这一点?

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

mzaanser1#

pipe=new each(管道,新字段(“k1”,“v2”),new identity(),fields.results);

hrysbysz

hrysbysz2#

可以使用“保留管道”并传递要保留的字段。
你的例子看起来像

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

相关问题