Uses of Class
org.apache.paimon.crosspartition.KeyPartOrRow

Packages that use KeyPartOrRow

Package	Description
org.apache.paimon.crosspartition
org.apache.paimon.flink.sink.index

Uses of KeyPartOrRow in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition that return KeyPartOrRow

Modifier and Type	Method and Description
static KeyPartOrRow	KeyPartOrRow.fromByteValue(byte value)
static KeyPartOrRow	KeyPartOrRow.valueOf(String name) Returns the enum constant of this type with the specified name.
static KeyPartOrRow[]	KeyPartOrRow.values() Returns an array containing the constants of this enum type, in the order they are declared.

Uses of KeyPartOrRow in org.apache.paimon.flink.sink.index

Methods in org.apache.paimon.flink.sink.index that return types with arguments of type KeyPartOrRow

Modifier and Type	Method and Description
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	KeyWithRowSerializer.copy(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> from)
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	KeyWithRowSerializer.createInstance()
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	KeyWithRowSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>>	KeyWithRowSerializer.duplicate()

Method parameters in org.apache.paimon.flink.sink.index with type arguments of type KeyPartOrRow

Modifier and Type	Method and Description
int	KeyPartRowChannelComputer.channel(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow> record)
org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T>	KeyWithRowSerializer.copy(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> from)
void	GlobalIndexAssignerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow>> streamRecord)
void	KeyWithRowSerializer.serialize(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,T> record, org.apache.flink.core.memory.DataOutputView target)