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 |
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<List<T>>> |
StateSnapshotTransformers.ListStateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<Map<K,V>>> |
StateSnapshotTransformers.MapStateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<T>> |
StateSnapshotTransformers.StateSnapshotTransformFactoryWrapAdaptor.createForDeserializedState() |
Optional<StateSnapshotTransformer<T>> |
StateSnapshotTransformer.StateSnapshotTransformFactory.createForDeserializedState() |
Optional<StateSnapshotTransformer<byte[]>> |
StateSnapshotTransformers.StateSnapshotTransformFactoryWrapAdaptor.createForSerializedState() |
Optional<StateSnapshotTransformer<byte[]>> |
StateSnapshotTransformer.StateSnapshotTransformFactory.createForSerializedState() |
Constructor and Description |
---|
ListStateSnapshotTransformer(StateSnapshotTransformer<T> entryValueTransformer) |
MapStateSnapshotTransformer(StateSnapshotTransformer<V> entryValueTransformer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.