org.apache.flink.table.runtime.operators.join.interval

Class PaddingRightMapFunction

java.lang.Object

org.apache.flink.table.runtime.operators.join.interval.PaddingRightMapFunction

All Implemented Interfaces:

Serializable, Function, MapFunction<RowData,RowData>, ResultTypeQueryable<RowData>

@Internal
public class PaddingRightMapFunction
extends Object
implements MapFunction<RowData,RowData>, ResultTypeQueryable<RowData>

Function performing right padding.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PaddingRightMapFunction(OuterJoinPaddingUtil paddingUtil, InternalTypeInfo<RowData> returnType)

Method Summary

Modifier and Type	Method and Description
TypeInformation<RowData>	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.
RowData	map(RowData value) The mapping method.

Methods inherited from class java.lang.Object

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

Constructor Detail

PaddingRightMapFunction

public PaddingRightMapFunction(OuterJoinPaddingUtil paddingUtil,
                               InternalTypeInfo<RowData> returnType)

Method Detail

map

public RowData map(RowData value)

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<RowData,RowData>

Parameters:

value - The input value.

Returns:

The transformed value

getProducedType

public TypeInformation<RowData> getProducedType()

Description copied from interface: ResultTypeQueryable

Gets the data type (as a TypeInformation) produced by this function or input format.

Specified by:

getProducedType in interface ResultTypeQueryable<RowData>

Returns:

The data type produced by this function or input format.