0

フィールドのリスト、つまり{field1、field2、field3、field4}があるとします。field2でいくつかの操作を実行したとします。たとえば、5などの値で各タプル値をインクリメントしたいとします。

performed this operation in a function which gave me modified field with "M_field2" as out field name now i want to write complete tuple in a file but in place of field2 i want "M_field2". How i will achieve this.
4

2 に答える 2

1

トライデントAPIページからそれは言う

関数は一連の入力フィールドを受け取り、出力として 0 個以上のタプルを発行します。出力タプルのフィールドは、ストリーム内の元の入力タプルに追加されます。関数がタプルを発行しない場合、元の入力タプルは除外されます。それ以外の場合、入力タプルは出力タプルごとに複製されます

トライデントのチュートリアル ページからさらに掘り下げると、これが見つかりまし
た。例えば：

    stream.groupBy(new Fields("val1"))
     .aggregate(new Fields("val2"), new Sum(), new Fields("sum"))

この例では、出力に fields が含まれます"val1" and "sum"。

よくわかりませんが、私が考えることができる最も近いものは、次のようなことをしています

    stream.groupBy(new Fields("field1","field3","field4"))
     .aggregate(new Fields("field2"), new Sum(), new Fields("M_field2"))

あなたが探しているものを達成するかもしれません。私が間違っている場合は修正してください。

于 2013-11-14T14:22:08.313 に答える