Package | Description |
---|---|
org.apache.flink.state.api |
Modifier and Type | Method and Description |
---|---|
KeyedOperatorTransformation<Tuple,T> |
OneInputOperatorTransformation.keyBy(int... fields)
Partitions the operator state of a
OperatorTransformation by the given key positions. |
<K> KeyedOperatorTransformation<K,T> |
OneInputOperatorTransformation.keyBy(KeySelector<T,K> keySelector)
It creates a new
KeyedOperatorTransformation that uses the provided key for
partitioning its operator states. |
<K> KeyedOperatorTransformation<K,T> |
OneInputOperatorTransformation.keyBy(KeySelector<T,K> keySelector,
TypeInformation<K> keyType)
It creates a new
KeyedOperatorTransformation that uses the provided key with explicit
type information for partitioning its operator states. |
KeyedOperatorTransformation<Tuple,T> |
OneInputOperatorTransformation.keyBy(String... fields)
Partitions the operator state of a
OperatorTransformation using field expressions. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.