KeyedStateTransformation<org.apache.flink.api.java.tuple.Tuple,T> |
OneInputStateTransformation.keyBy(int... fields) |
|
KeyedStateTransformation<org.apache.flink.api.java.tuple.Tuple,T> |
OneInputStateTransformation.keyBy(String... fields) |
|
<K> KeyedStateTransformation<K,T> |
OneInputStateTransformation.keyBy(org.apache.flink.api.java.functions.KeySelector<T,K> keySelector) |
|
<K> KeyedStateTransformation<K,T> |
OneInputStateTransformation.keyBy(org.apache.flink.api.java.functions.KeySelector<T,K> keySelector,
org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType) |
It creates a new KeyedOperatorTransformation that uses the provided key with explicit
type information for partitioning its operator states.
|