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

Class UnnestRowsWithOrdinalityFunction

java.lang.Object

org.apache.flink.table.runtime.functions.BuiltInSpecializedFunction

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

org.apache.flink.table.runtime.functions.table.UnnestRowsWithOrdinalityFunction

All Implemented Interfaces:

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

@Internal
public class UnnestRowsWithOrdinalityFunction
extends UnnestRowsFunctionBase

Flattens ARRAY, MAP, and MULTISET using a table function and adds one extra column with the position of the element. It does this by another level of specialization using a subclass of UnnestRowsFunctionBase.UnnestTableFunctionBase.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	UnnestRowsWithOrdinalityFunction.CollectionUnnestWithOrdinalityFunction	Table function that unwraps the elements of a collection (array or multiset) with ordinality.
static class	UnnestRowsWithOrdinalityFunction.MapUnnestWithOrdinalityFunction	Table function that unwraps the elements of a map with ordinality.

Nested classes/interfaces inherited from class org.apache.flink.table.runtime.functions.table.UnnestRowsFunctionBase

UnnestRowsFunctionBase.UnnestTableFunctionBase

Nested classes/interfaces inherited from interface org.apache.flink.table.functions.SpecializedFunction

org.apache.flink.table.functions.SpecializedFunction.ExpressionEvaluator, org.apache.flink.table.functions.SpecializedFunction.ExpressionEvaluatorFactory, org.apache.flink.table.functions.SpecializedFunction.SpecializedContext

Constructor Summary

Constructors

Constructor	Description
UnnestRowsWithOrdinalityFunction()

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.table.functions.UserDefinedFunction	createCollectionUnnestFunction(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context, org.apache.flink.table.types.logical.LogicalType elementType, org.apache.flink.table.data.ArrayData.ElementGetter elementGetter)
protected org.apache.flink.table.functions.UserDefinedFunction	createMapUnnestFunction(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context, org.apache.flink.table.types.logical.RowType keyValTypes, org.apache.flink.table.data.ArrayData.ElementGetter keyGetter, org.apache.flink.table.data.ArrayData.ElementGetter valueGetter)

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

getUnnestedType, specialize, wrapWithOrdinality

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

getKind, getRequirements, getTypeInference, isDeterministic

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.table.functions.FunctionDefinition

supportsConstantFolding

Constructor Detail

UnnestRowsWithOrdinalityFunction

public UnnestRowsWithOrdinalityFunction()

Method Detail

createCollectionUnnestFunction

protected org.apache.flink.table.functions.UserDefinedFunction createCollectionUnnestFunction(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context,
                                                                                              org.apache.flink.table.types.logical.LogicalType elementType,
                                                                                              org.apache.flink.table.data.ArrayData.ElementGetter elementGetter)

Specified by:

createCollectionUnnestFunction in class UnnestRowsFunctionBase

createMapUnnestFunction

protected org.apache.flink.table.functions.UserDefinedFunction createMapUnnestFunction(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context,
                                                                                       org.apache.flink.table.types.logical.RowType keyValTypes,
                                                                                       org.apache.flink.table.data.ArrayData.ElementGetter keyGetter,
                                                                                       org.apache.flink.table.data.ArrayData.ElementGetter valueGetter)

Specified by:

createMapUnnestFunction in class UnnestRowsFunctionBase