@Internal public interface InternalKeyContext<K>
The typical use case for this interface is providing a view on the current-key selection aspects of
KeyedStateBackend
.
Modifier and Type | Method and Description |
---|---|
K |
getCurrentKey()
Used by states to access the current key.
|
int |
getCurrentKeyGroupIndex()
Returns the key-group to which the current key belongs.
|
KeyGroupRange |
getKeyGroupRange()
Returns the key groups for this backend.
|
TypeSerializer<K> |
getKeySerializer()
TypeSerializer for the state backend key type. |
int |
getNumberOfKeyGroups()
Returns the number of key-groups aka max parallelism.
|
K getCurrentKey()
int getCurrentKeyGroupIndex()
int getNumberOfKeyGroups()
KeyGroupRange getKeyGroupRange()
TypeSerializer<K> getKeySerializer()
TypeSerializer
for the state backend key type.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.