Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
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 |
Class and Description |
---|
HeapPriorityQueueElement
Interface for objects that can be managed by a
HeapPriorityQueue . |
InternalKeyContext
This interface is the current context of a keyed state.
|
Class and Description |
---|
HeapPriorityQueueElement
Interface for objects that can be managed by a
HeapPriorityQueue . |
InternalKeyContext
This interface is the current context of a keyed state.
|
Class and Description |
---|
AbstractHeapPriorityQueue
Abstract base class for heap (object array) based implementations of priority queues, with support for fast deletes
via
HeapPriorityQueueElement . |
CopyOnWriteStateTableSnapshot
This class represents the snapshot of a
CopyOnWriteStateTable and has a role in operator state checkpointing. |
CopyOnWriteStateTableSnapshot.StateTableKeyGroupPartitioner
This class is the implementation of
KeyGroupPartitioner for CopyOnWriteStateTable . |
HeapPriorityQueue
Basic heap-based priority queue for
HeapPriorityQueueElement objects. |
HeapPriorityQueueElement
Interface for objects that can be managed by a
HeapPriorityQueue . |
HeapPriorityQueueSet
A heap-based priority queue with set semantics, based on
HeapPriorityQueue . |
HeapPriorityQueueSetFactory
Factory for
HeapPriorityQueueSet . |
HeapPriorityQueueSnapshotRestoreWrapper
This wrapper combines a HeapPriorityQueue with backend meta data.
|
InternalKeyContext
This interface is the current context of a keyed state.
|
KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory
Factory that produces the sub-queues that represent the partitions of a
KeyGroupPartitionedPriorityQueue . |
StateEntry
Interface of entries in a state table.
|
StateTable
Base class for state tables.
|
Class and Description |
---|
HeapPriorityQueueElement
Interface for objects that can be managed by a
HeapPriorityQueue . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.