Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.iterator | |
org.apache.flink.runtime.state |
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 |
StateSnapshotTransformer.ListStateSnapshotTransformer<T>
General implementation of list state transformer.
|
static class |
StateSnapshotTransformer.MapStateSnapshotTransformer<K,V>
General implementation of map state transformer.
|
Modifier and Type | Method and Description |
---|---|
StateSnapshotTransformer<S> |
RegisteredKeyValueStateBackendMetaInfo.getSnapshotTransformer() |
Modifier and Type | Method and Description |
---|---|
Optional<StateSnapshotTransformer<T>> |
StateSnapshotTransformer.StateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<byte[]>> |
StateSnapshotTransformer.StateSnapshotTransformFactory.createForSerializedState() |
Modifier and Type | Method and Description |
---|---|
void |
RegisteredKeyValueStateBackendMetaInfo.updateSnapshotTransformer(StateSnapshotTransformer<S> snapshotTransformer) |
Constructor and Description |
---|
ListStateSnapshotTransformer(StateSnapshotTransformer<T> entryValueTransformer) |
MapStateSnapshotTransformer(StateSnapshotTransformer<V> entryValueTransformer) |
RegisteredKeyValueStateBackendMetaInfo(StateDescriptor.Type stateType,
String name,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> snapshotTransformer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.