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.
|
org.apache.flink.streaming.api.operators |
Modifier and Type | Field and Description |
---|---|
static KeyExtractorFunction<? extends Keyed<?>> |
KeyExtractorFunction.FOR_KEYED_OBJECTS |
Modifier and Type | Method and Description |
---|---|
static <T extends Keyed<?>> |
KeyExtractorFunction.forKeyedObjects() |
Constructor and Description |
---|
KeyGroupPartitioner(T[] partitioningSource,
int numberOfElements,
T[] partitioningDestination,
KeyGroupRange keyGroupRange,
int totalKeyGroups,
KeyExtractorFunction<T> keyExtractorFunction,
KeyGroupPartitioner.ElementWriterFunction<T> elementWriterFunction)
Creates a new
KeyGroupPartitioner . |
Modifier and Type | Method and Description |
---|---|
PQS |
KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory.create(int keyGroupId,
int numKeyGroups,
KeyExtractorFunction<T> keyExtractorFunction,
PriorityComparator<T> elementPriorityComparator)
Creates a new queue for a given key-group partition.
|
Constructor and Description |
---|
HeapPriorityQueueSet(PriorityComparator<T> elementPriorityComparator,
KeyExtractorFunction<T> keyExtractor,
int minimumCapacity,
KeyGroupRange keyGroupRange,
int totalNumberOfKeyGroups)
Creates an empty
HeapPriorityQueueSet with the requested initial capacity. |
HeapPriorityQueueSnapshotRestoreWrapper(HeapPriorityQueueSet<T> priorityQueue,
RegisteredPriorityQueueStateBackendMetaInfo<T> metaInfo,
KeyExtractorFunction<T> keyExtractorFunction,
KeyGroupRange localKeyGroupRange,
int totalKeyGroups) |
KeyGroupPartitionedPriorityQueue(KeyExtractorFunction<T> keyExtractor,
PriorityComparator<T> elementPriorityComparator,
KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory<T,PQ> orderedCacheFactory,
KeyGroupRange keyGroupRange,
int totalKeyGroups) |
Modifier and Type | Field and Description |
---|---|
static KeyExtractorFunction<InternalTimer<?,?>> |
InternalTimer.KEY_EXTRACTOR_FUNCTION
Function to extract the key from a
InternalTimer . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.