WithKeys

Javadoc

接受一个 PCollection<V> 并通过将每个输入元素与一个键关联来生成一个 PCollection<KV<K, V>>。

WithKeys 有两个版本，具体取决于如何确定键

• WithKeys.of(SerializableFunction<V, K> fn) 接受一个函数，用于从每个值计算键。
• WithKeys.of(K key) 将每个值与指定的键关联。

示例

相关转换

• Keys 用于提取每个组件的键。
• Values 用于提取每个元素的值。
• KvSwap 交换键值对值。