Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.io.network.api.writer |
Modifier and Type | Field and Description |
---|---|
protected DataOutputSerializer |
AbstractRocksDBState.dataOutputView |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRocksDBState.migrateSerializedValue(DataInputDeserializer serializedOldValueInput,
DataOutputSerializer serializedMigratedValueOutput,
TypeSerializer<V> priorSerializer,
TypeSerializer<V> newSerializer) |
static <K> void |
RocksDBKeySerializationUtils.writeKey(K key,
TypeSerializer<K> keySerializer,
DataOutputSerializer keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
static <N> void |
RocksDBKeySerializationUtils.writeNameSpace(N namespace,
TypeSerializer<N> namespaceSerializer,
DataOutputSerializer keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
Modifier and Type | Field and Description |
---|---|
protected DataOutputSerializer |
RecordWriter.serializer |
Modifier and Type | Method and Description |
---|---|
static ByteBuffer |
RecordWriter.serializeRecord(DataOutputSerializer serializer,
IOReadableWritable record) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.