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