WithKeys

Javadoc

接受 PCollection<V> 並產生 PCollection<KV<K, V>>，方法是將每個輸入元素與一個鍵關聯。

WithKeys 有兩個版本，具體取決於應如何決定鍵

• WithKeys.of(SerializableFunction<V, K> fn) 接受一個函式，以從每個值計算鍵。
• WithKeys.of(K key) 將每個值與指定的鍵關聯。

範例

相關轉換

• Keys 用於擷取每個元件的鍵。
• Values 用於擷取每個元素的值。
• KvSwap 交換鍵值對值。