public class KeyValueSerializer extends ObjectSerializer<KeyValue>
KeyValue
.
NOTE: InternalRow
and KeyValue
produced by this serializer are reused.
rowSerializer
Constructor and Description |
---|
KeyValueSerializer(RowType keyType,
RowType valueType) |
Modifier and Type | Method and Description |
---|---|
KeyValue |
fromRow(InternalRow row)
Convert a
InternalRow to T . |
KeyValue |
getReusedKv() |
InternalRow |
toRow(InternalRow key,
long sequenceNumber,
RowKind valueKind,
InternalRow value) |
InternalRow |
toRow(KeyValue record)
Convert a
T to InternalRow . |
deserialize, deserializeFromBytes, deserializeList, deserializeList, fieldTypes, numFields, serialize, serializeList, serializeList, serializeToBytes
public InternalRow toRow(KeyValue record)
ObjectSerializer
T
to InternalRow
.toRow
in class ObjectSerializer<KeyValue>
public InternalRow toRow(InternalRow key, long sequenceNumber, RowKind valueKind, InternalRow value)
public KeyValue fromRow(InternalRow row)
ObjectSerializer
InternalRow
to T
.fromRow
in class ObjectSerializer<KeyValue>
public KeyValue getReusedKv()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.