Package org.apache.flink.table.runtime.functions.table

Class UnnestRowsFunctionBase.UnnestTableFunctionBase

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.TableFunction<T>

org.apache.flink.table.runtime.functions.table.BuiltInTableFunction<Object>

org.apache.flink.table.runtime.functions.table.UnnestRowsFunctionBase.UnnestTableFunctionBase

All Implemented Interfaces:

Serializable, org.apache.flink.table.functions.FunctionDefinition

Direct Known Subclasses:

UnnestRowsFunction.CollectionUnnestFunction, UnnestRowsFunction.MapUnnestFunction, UnnestRowsWithOrdinalityFunction.CollectionUnnestWithOrdinalityFunction, UnnestRowsWithOrdinalityFunction.MapUnnestWithOrdinalityFunction

Enclosing class:

UnnestRowsFunctionBase

protected abstract static class UnnestRowsFunctionBase.UnnestTableFunctionBase
extends BuiltInTableFunction<Object>

Base class for table functions that unwrap collections and maps.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	UnnestRowsFunctionBase.UnnestTableFunctionBase.MapUnnestCollector
protected static interface	UnnestRowsFunctionBase.UnnestTableFunctionBase.UnnestCollector

Method Summary

Modifier and Type	Method	Description
protected void	evalArrayData(org.apache.flink.table.data.ArrayData arrayData, org.apache.flink.table.data.ArrayData.ElementGetter elementGetter, UnnestRowsFunctionBase.UnnestTableFunctionBase.UnnestCollector collector)
protected void	evalMapData(org.apache.flink.table.data.MapData mapData, org.apache.flink.table.data.ArrayData.ElementGetter keyGetter, org.apache.flink.table.data.ArrayData.ElementGetter valueGetter, UnnestRowsFunctionBase.UnnestTableFunctionBase.MapUnnestCollector collector)
protected void	evalMultisetData(org.apache.flink.table.data.MapData mapData, org.apache.flink.table.data.ArrayData.ElementGetter elementGetter, UnnestRowsFunctionBase.UnnestTableFunctionBase.UnnestCollector collector)
org.apache.flink.table.types.DataType	getOutputDataType()

Methods inherited from class org.apache.flink.table.runtime.functions.table.BuiltInTableFunction

getArgumentDataTypes, getRequirements, getTypeInference, isDeterministic

Methods inherited from class org.apache.flink.table.functions.TableFunction

collect, finish, getKind, getParameterTypes, getResultType, setCollector

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, open, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

supportsConstantFolding

Method Detail

getOutputDataType

public org.apache.flink.table.types.DataType getOutputDataType()

Overrides:

getOutputDataType in class BuiltInTableFunction<Object>

evalArrayData

protected void evalArrayData(org.apache.flink.table.data.ArrayData arrayData,
                             org.apache.flink.table.data.ArrayData.ElementGetter elementGetter,
                             UnnestRowsFunctionBase.UnnestTableFunctionBase.UnnestCollector collector)

evalMapData

protected void evalMapData(org.apache.flink.table.data.MapData mapData,
                           org.apache.flink.table.data.ArrayData.ElementGetter keyGetter,
                           org.apache.flink.table.data.ArrayData.ElementGetter valueGetter,
                           UnnestRowsFunctionBase.UnnestTableFunctionBase.MapUnnestCollector collector)

evalMultisetData

protected void evalMultisetData(org.apache.flink.table.data.MapData mapData,
                                org.apache.flink.table.data.ArrayData.ElementGetter elementGetter,
                                UnnestRowsFunctionBase.UnnestTableFunctionBase.UnnestCollector collector)