FilterAllFlatMapFunction (Flink : Table : Runtime 1.18.1-cp3 API)

java.lang.Object
- org.apache.flink.table.runtime.operators.join.interval.FilterAllFlatMapFunction

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>, org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>
```
@Internal
public class FilterAllFlatMapFunction
extends Object
implements org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>
```
Function filtering out all the input records.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

FilterAllFlatMapFunction(InternalTypeInfo<org.apache.flink.table.data.RowData> inputTypeInfo)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`flatMap(org.apache.flink.table.data.RowData value, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)`
`org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData>`	`getProducedType()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FilterAllFlatMapFunction

public FilterAllFlatMapFunction(InternalTypeInfo<org.apache.flink.table.data.RowData> inputTypeInfo)

Method Detail
- flatMap
```
public void flatMap(org.apache.flink.table.data.RowData value,
                    org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
```
  Specified by:
  
  flatMap in interface org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>
- getProducedType
```
public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> getProducedType()
```
  Specified by:
  
  getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>