org.apache.paimon.flink.shuffle

Class RangeShuffle.KeyAndSizeExtractor<T>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>,org.apache.flink.api.java.tuple.Tuple2<T,Integer>>

org.apache.paimon.flink.shuffle.RangeShuffle.KeyAndSizeExtractor<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>,org.apache.flink.api.java.tuple.Tuple2<T,Integer>>, org.apache.flink.api.common.functions.RichFunction

Enclosing class:

RangeShuffle

public static class RangeShuffle.KeyAndSizeExtractor<T>
extends org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>,org.apache.flink.api.java.tuple.Tuple2<T,Integer>>

KeyAndSizeExtractor is responsible for extracting the sort key and row size.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyAndSizeExtractor(RowType rowType, boolean isSortBySize)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.tuple.Tuple2<T,Integer>	map(org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData> keyAndRowData)
void	open(org.apache.flink.configuration.Configuration parameters) Do not annotate with @override here to maintain compatibility with Flink 2.0+.
void	open(OpenContext openContext) Do not annotate with @override here to maintain compatibility with Flink 1.18-.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyAndSizeExtractor

public KeyAndSizeExtractor(RowType rowType,
                           boolean isSortBySize)

Method Detail

open

public void open(OpenContext openContext)
          throws Exception

Do not annotate with @override here to maintain compatibility with Flink 1.18-.

Throws:

Exception

open

public void open(org.apache.flink.configuration.Configuration parameters)
          throws Exception

Do not annotate with @override here to maintain compatibility with Flink 2.0+.

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception

map

public org.apache.flink.api.java.tuple.Tuple2<T,Integer> map(org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData> keyAndRowData)
                                                      throws Exception

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>,org.apache.flink.api.java.tuple.Tuple2<T,Integer>>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<T,org.apache.flink.table.data.RowData>,org.apache.flink.api.java.tuple.Tuple2<T,Integer>>

Throws:

Exception