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

Packages that use Keyed

Package	Description
org.apache.flink.runtime.state
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.

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

Fields in org.apache.flink.runtime.state with type parameters of type Keyed

Modifier and Type	Field	Description
static KeyExtractorFunction<? extends Keyed<?>>	KeyExtractorFunction.FOR_KEYED_OBJECTS

Methods in org.apache.flink.runtime.state with type parameters of type Keyed

Modifier and Type	Method	Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)	Creates a KeyGroupedInternalPriorityQueue.
default <T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)	Creates a KeyGroupedInternalPriorityQueue.
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapPriorityQueuesManager.createOrUpdate(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapPriorityQueuesManager.createOrUpdate(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)
static <T extends Keyed<?>> KeyExtractorFunction<T>	KeyExtractorFunction.forKeyedObjects()

Uses of Keyed in org.apache.flink.runtime.state.heap

Methods in org.apache.flink.runtime.state.heap with type parameters of type Keyed

Modifier and Type	Method	Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> HeapPriorityQueueSet<T>	HeapPriorityQueueSetFactory.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)