org.apache.paimon.flink.sink.index

Class KeyWithRowSerializer<T>

java.lang.Object

org.apache.flink.api.common.typeutils.TypeSerializer<T>

org.apache.paimon.flink.utils.InternalTypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

org.apache.paimon.flink.sink.index.KeyWithRowSerializer<T>

All Implemented Interfaces:

Serializable

public class KeyWithRowSerializer<T>
extends InternalTypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

A InternalTypeSerializer to serialize KeyPartOrRow with T.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyWithRowSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> keyPartSerializer, org.apache.flink.api.common.typeutils.TypeSerializer<T> rowSerializer)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	copy(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> from)
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	createInstance()
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	deserialize(org.apache.flink.core.memory.DataInputView source)
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>	duplicate()
boolean	equals(Object o)
int	hashCode()
void	serialize(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> record, org.apache.flink.core.memory.DataOutputView target)

Methods inherited from class org.apache.paimon.flink.utils.InternalTypeSerializer

copy, copy, deserialize, getLength, isImmutableType, snapshotConfiguration

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KeyWithRowSerializer

public KeyWithRowSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> keyPartSerializer,
                            org.apache.flink.api.common.typeutils.TypeSerializer<T> rowSerializer)

Method Detail

duplicate

public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>> duplicate()

Specified by:

duplicate in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

createInstance

public org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> createInstance()

Specified by:

createInstance in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

copy

public org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> copy(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> from)

Specified by:

copy in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

serialize

public void serialize(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> record,
                      org.apache.flink.core.memory.DataOutputView target)
               throws IOException

Specified by:

serialize in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

Throws:

IOException

deserialize

public org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> deserialize(org.apache.flink.core.memory.DataInputView source)
                                                                   throws IOException

Specified by:

deserialize in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

Throws:

IOException

equals

public boolean equals(Object o)

Specified by:

equals in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>

hashCode

public int hashCode()

Specified by:

hashCode in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>