Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.contrib.streaming.state.iterator | |
org.apache.flink.runtime.state |
Modifier and Type | Field and Description |
---|---|
protected DataInputDeserializer |
AbstractRocksDBState.dataInputView |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRocksDBState.migrateSerializedValue(DataInputDeserializer serializedOldValueInput,
DataOutputSerializer serializedMigratedValueOutput,
TypeSerializer<V> priorSerializer,
TypeSerializer<V> newSerializer) |
Modifier and Type | Field and Description |
---|---|
protected DataInputDeserializer |
AbstractRocksStateKeysIterator.byteArrayDataInputView |
Modifier and Type | Method and Description |
---|---|
protected K |
AbstractRocksStateKeysIterator.deserializeKey(byte[] keyBytes,
DataInputDeserializer readView) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
ListDelimitedSerializer.deserializeNextElement(DataInputDeserializer in,
TypeSerializer<T> elementSerializer)
Deserializes a single element from a serialized list.
|
static <K> K |
CompositeKeySerializationUtils.readKey(TypeSerializer<K> keySerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
static <N> N |
CompositeKeySerializationUtils.readNamespace(TypeSerializer<N> namespaceSerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.