Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.contrib.streaming.state.iterator |
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) |
static <K> K |
RocksDBKeySerializationUtils.readKey(TypeSerializer<K> keySerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
static <N> N |
RocksDBKeySerializationUtils.readNamespace(TypeSerializer<N> namespaceSerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
Modifier and Type | Field and Description |
---|---|
protected DataInputDeserializer |
AbstractRocksStateKeysIterator.byteArrayDataInputView |
Modifier and Type | Method and Description |
---|---|
protected K |
AbstractRocksStateKeysIterator.deserializeKey(byte[] keyBytes,
DataInputDeserializer readView) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.