Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.migration.runtime.state.filesystem | |
org.apache.flink.migration.runtime.state.memory | |
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.
|
Class and Description |
---|
InternalKeyContext
This interface is the current context of a keyed state.
|
Class and Description |
---|
HeapKeyedStateBackend
A
AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
StateTable
Base class for state tables.
|
Class and Description |
---|
HeapKeyedStateBackend
A
AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to
streams provided by a CheckpointStreamFactory upon
checkpointing. |
StateTable
Base class for state tables.
|
Class and Description |
---|
InternalKeyContext
This interface is the current context of a keyed state.
|
Class and Description |
---|
AbstractHeapMergingState
Base class for
MergingState (InternalMergingState )
that is stored on the heap. |
AbstractHeapState
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
CopyOnWriteStateTableSnapshot
This class represents the snapshot of a
CopyOnWriteStateTable and has a role in operator state checkpointing. |
InternalKeyContext
This interface is the current context of a keyed state.
|
StateEntry
Interface of entries in a state table.
|
StateTable
Base class for state tables.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.