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.
|
Class and Description |
---|
InternalKeyContext
This interface is the current context of a keyed state.
|
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
State 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–2019 The Apache Software Foundation. All rights reserved.