MapElements

Javadoc

コレクション内の各要素に単純な 1 対 1 のマッピング関数を適用します。

例

例 1: SimpleFunction を使用してマッピング関数を提供する場合

例 2: Java 8 のラムダの使用を可能にする SerializableFunction を使用してマッピング関数を提供する場合。型の消去により、必要な戻り型を示すヒントを提供する必要があります。

PCollection<String> lines = Create.of("Hello World", "Beam is fun");
PCollection<Integer> lineLengths = lines.apply(MapElements
    .into(TypeDescriptors.integers())
    .via((String line) -> line.length()));

関連する変換

• FlatMapElements は Map と同じように動作しますが、入力ごとに 0 個以上の出力を生成する場合があります。
• 関数が要素を出力するかどうかを決定するだけの場合、Filter が役立ちます。
• ParDo は最も一般的な要素単位のマッピング操作であり、複数の出力コレクションやサイド入力などの他の機能も含まれます。