キーの追加 (WithKeys)

Javadoc

PCollection<V>を受け取り、各入力要素にキーを関連付けることで、PCollection<KV<K, V>>を生成します。

キーの決定方法に応じて、WithKeysには2つのバージョンがあります。

• WithKeys.of(SerializableFunction<V, K> fn)は、各値からキーを計算する関数を受け取ります。
• WithKeys.of(K key)は、各値を指定されたキーに関連付けます。

例

関連する変換

• 各コンポーネントのキーを抽出するには、Keysを使用します。
• 各要素の値を抽出するには、Valuesを使用します。
• キーと値のペアの値を入れ替えるには、KvSwapを使用します。