public class KeyValueSerializer extends ObjectSerializer<KeyValue>
rowSerializer
Constructor and Description |
---|
KeyValueSerializer(org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType) |
Modifier and Type | Method and Description |
---|---|
KeyValue |
fromRow(org.apache.flink.table.data.RowData row)
Convert a
RowData to T . |
KeyValue |
getReusedKv() |
org.apache.flink.table.data.RowData |
toRow(KeyValue record)
Convert a
T to RowData . |
org.apache.flink.table.data.RowData |
toRow(org.apache.flink.table.data.RowData key,
long sequenceNumber,
org.apache.flink.types.RowKind valueKind,
org.apache.flink.table.data.RowData value) |
deserialize, deserializeList, deserializeList, numFields, serialize, serializeList, serializeList
public KeyValueSerializer(org.apache.flink.table.types.logical.RowType keyType, org.apache.flink.table.types.logical.RowType valueType)
public org.apache.flink.table.data.RowData toRow(KeyValue record)
ObjectSerializer
T
to RowData
.toRow
in class ObjectSerializer<KeyValue>
public org.apache.flink.table.data.RowData toRow(org.apache.flink.table.data.RowData key, long sequenceNumber, org.apache.flink.types.RowKind valueKind, org.apache.flink.table.data.RowData value)
public KeyValue fromRow(org.apache.flink.table.data.RowData row)
ObjectSerializer
RowData
to T
.fromRow
in class ObjectSerializer<KeyValue>
public KeyValue getReusedKv()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.