Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.iterator | |
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.
|
Constructor and Description |
---|
RocksTransformingIteratorWrapper(org.rocksdb.RocksIterator iterator,
StateSnapshotTransformer<byte[]> stateSnapshotTransformer) |
Modifier and Type | Interface and Description |
---|---|
static interface |
StateSnapshotTransformer.CollectionStateSnapshotTransformer<T>
Collection state specific transformer which says how to transform entries of the collection.
|
Modifier and Type | Class and Description |
---|---|
static class |
StateSnapshotTransformers.ListStateSnapshotTransformer<T>
General implementation of list state transformer.
|
static class |
StateSnapshotTransformers.MapStateSnapshotTransformer<K,V>
General implementation of map state transformer.
|
Modifier and Type | Method and Description |
---|---|
Optional<StateSnapshotTransformer<T>> |
StateSnapshotTransformer.StateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<List<T>>> |
StateSnapshotTransformers.ListStateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<Map<K,V>>> |
StateSnapshotTransformers.MapStateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<T>> |
StateSnapshotTransformers.StateSnapshotTransformFactoryWrapAdaptor.createForDeserializedState() |
Optional<StateSnapshotTransformer<byte[]>> |
StateSnapshotTransformer.StateSnapshotTransformFactory.createForSerializedState() |
Optional<StateSnapshotTransformer<byte[]>> |
StateSnapshotTransformers.StateSnapshotTransformFactoryWrapAdaptor.createForSerializedState() |
Modifier and Type | Method and Description |
---|---|
default StateEntry<K,N,S> |
StateEntry.filterOrTransform(StateSnapshotTransformer<S> transformer) |
Constructor and Description |
---|
ListStateSnapshotTransformer(StateSnapshotTransformer<T> entryValueTransformer) |
MapStateSnapshotTransformer(StateSnapshotTransformer<V> entryValueTransformer) |
Modifier and Type | Method and Description |
---|---|
Iterator<StateEntry<K,N,S>> |
CopyOnWriteSkipListStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract Iterator<StateEntry<K,N,S>> |
StateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
org.apache.flink.runtime.state.heap.CopyOnWriteStateMapSnapshot.SnapshotIterator<K,N,S> |
CopyOnWriteStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
void |
CopyOnWriteSkipListStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract void |
StateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer)
Writes the state in this snapshot to output.
|
void |
CopyOnWriteStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.