Uses of Interface
org.apache.flink.runtime.state.KeyGroupsList

Packages that use KeyGroupsList

Package	Description
org.apache.flink.runtime.state
org.apache.flink.streaming.api.operators

Uses of KeyGroupsList in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state that implement KeyGroupsList

Modifier and Type	Class and Description
class	KeyGroupRange This class defines a range of key-group indexes.

Methods in org.apache.flink.runtime.state that return KeyGroupsList

Modifier and Type	Method and Description
KeyGroupsList	KeyedStateCheckpointOutputStream.getKeyGroupList() Returns a list of all key-groups which can be written to this stream.

Uses of KeyGroupsList in org.apache.flink.streaming.api.operators

Constructors in org.apache.flink.streaming.api.operators with parameters of type KeyGroupsList

Constructor and Description
HeapInternalTimerService(int totalKeyGroups, KeyGroupsList localKeyGroupRange, KeyContext keyContext, ProcessingTimeService processingTimeService)
InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServicesMapToPopulate, ClassLoader userCodeClassLoader, int totalKeyGroups, KeyGroupsList localKeyGroupRange, KeyContext keyContext, ProcessingTimeService processingTimeService, int keyGroupIdx) Constructor to use when restoring timer services.