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 PriorityComparator<? extends PriorityComparable<Object>> |
PriorityComparator.FOR_PRIORITY_COMPARABLE_OBJECTS |
Modifier and Type | Method and Description |
---|---|
static <T extends PriorityComparable<?>> |
PriorityComparator.forPriorityComparableObjects() |
Modifier and Type | Field and Description |
---|---|
protected PriorityComparator<T> |
HeapPriorityQueue.elementPriorityComparator
Comparator for the priority of contained elements.
|
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 |
---|
HeapPriorityQueue(PriorityComparator<T> elementPriorityComparator,
int minimumCapacity)
Creates an empty
HeapPriorityQueue with the requested initial capacity. |
HeapPriorityQueueSet(PriorityComparator<T> elementPriorityComparator,
KeyExtractorFunction<T> keyExtractor,
int minimumCapacity,
KeyGroupRange keyGroupRange,
int totalNumberOfKeyGroups)
Creates an empty
HeapPriorityQueueSet with the requested initial capacity. |
KeyGroupPartitionedPriorityQueue(KeyExtractorFunction<T> keyExtractor,
PriorityComparator<T> elementPriorityComparator,
KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory<T,PQ> orderedCacheFactory,
KeyGroupRange keyGroupRange,
int totalKeyGroups) |
Modifier and Type | Field and Description |
---|---|
static PriorityComparator<InternalTimer<?,?>> |
InternalTimer.TIMER_COMPARATOR
Function to compare instances of
InternalTimer . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.