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

Class FilterAllFlatMapFunction

java.lang.Object

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

All Implemented Interfaces:

Serializable, FlatMapFunction<RowData,RowData>, Function, ResultTypeQueryable<RowData>

@Internal
public class FilterAllFlatMapFunction
extends Object
implements FlatMapFunction<RowData,RowData>, ResultTypeQueryable<RowData>

Function filtering out all the input records.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FilterAllFlatMapFunction(InternalTypeInfo<RowData> inputTypeInfo)

Method Summary

Modifier and Type	Method and Description
void	flatMap(RowData value, Collector<RowData> out) The core method of the FlatMapFunction.
TypeInformation<RowData>	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.

Methods inherited from class java.lang.Object

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

Constructor Detail

FilterAllFlatMapFunction

public FilterAllFlatMapFunction(InternalTypeInfo<RowData> inputTypeInfo)

Method Detail

flatMap

public void flatMap(RowData value,
                    Collector<RowData> out)

Description copied from interface: FlatMapFunction

The core method of the FlatMapFunction. Takes an element from the input data set and transforms it into zero, one, or more elements.

Specified by:

flatMap in interface FlatMapFunction<RowData,RowData>

Parameters:

value - The input value.

out - The collector for returning result values.

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.