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)

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

Methods inherited from interface org.apache.flink.api.common.functions.RichFunction

open

Constructor Detail

KeyAndSizeExtractor

public KeyAndSizeExtractor(RowType rowType,
                           boolean isSortBySize)

Method Detail

open

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

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