org.apache.flink.runtime.state

Interface KeyedStateHandle

All Superinterfaces:

CompositeStateHandle, Serializable, StateObject

All Known Subinterfaces:

IncrementalKeyedStateHandle

All Known Implementing Classes:

DirectoryKeyedStateHandle, IncrementalLocalKeyedStateHandle, IncrementalRemoteKeyedStateHandle, KeyGroupsStateHandle

public interface KeyedStateHandle
extends CompositeStateHandle

Base for the handles of the checkpointed states in keyed streams. When recovering from failures, the handle will be passed to all tasks whose key group ranges overlap with it.

Method Summary

Modifier and Type	Method and Description
KeyedStateHandle	getIntersection(KeyGroupRange keyGroupRange) Returns a state over a range that is the intersection between this handle's key-group range and the provided key-group range.
KeyGroupRange	getKeyGroupRange() Returns the range of the key groups contained in the state.

Methods inherited from interface org.apache.flink.runtime.state.CompositeStateHandle

registerSharedStates

Methods inherited from interface org.apache.flink.runtime.state.StateObject

discardState, getStateSize

Method Detail

getKeyGroupRange

KeyGroupRange getKeyGroupRange()

Returns the range of the key groups contained in the state.

getIntersection

@Nullable
KeyedStateHandle getIntersection(KeyGroupRange keyGroupRange)

Returns a state over a range that is the intersection between this handle's key-group range and the provided key-group range.

Parameters:

keyGroupRange - The key group range to intersect with, will return null if the intersection of this handle's key-group and the provided key-group is empty.