public class KeyWithRowSerializer<T> extends InternalTypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
InternalTypeSerializer
to serialize KeyPartOrRow with T.Constructor and Description |
---|
KeyWithRowSerializer(org.apache.flink.api.common.typeutils.TypeSerializer<T> keyPartSerializer,
org.apache.flink.api.common.typeutils.TypeSerializer<T> rowSerializer) |
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) |
copy, copy, deserialize, getLength, isImmutableType, snapshotConfiguration
public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>> duplicate()
duplicate
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
public org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> createInstance()
createInstance
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
public org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> copy(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> from)
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
public void serialize(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> record, org.apache.flink.core.memory.DataOutputView target) throws IOException
serialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
IOException
public org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> deserialize(org.apache.flink.core.memory.DataInputView source) throws IOException
deserialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
IOException
public boolean equals(Object o)
equals
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
public int hashCode()
hashCode
in class org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.