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

Class UnnestRowsFunctionBase

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

UnnestRowsFunction, UnnestRowsWithOrdinalityFunction

@Internal
public abstract class UnnestRowsFunctionBase
extends BuiltInSpecializedFunction

Base class for flattening ARRAY, MAP, and MULTISET using a table function.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	UnnestRowsFunctionBase.UnnestTableFunctionBase	Base class for table functions that unwrap collections and maps.

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
UnnestRowsFunctionBase(boolean withOrdinality)

Method Summary

Modifier and Type	Method	Description
protected abstract 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 abstract 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)
static org.apache.flink.table.types.logical.LogicalType	getUnnestedType(org.apache.flink.table.types.logical.LogicalType logicalType, boolean withOrdinality)
org.apache.flink.table.functions.UserDefinedFunction	specialize(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context)
static org.apache.flink.table.types.logical.LogicalType	wrapWithOrdinality(org.apache.flink.table.types.logical.LogicalType baseType)

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

UnnestRowsFunctionBase

public UnnestRowsFunctionBase(boolean withOrdinality)

Method Detail

specialize

public org.apache.flink.table.functions.UserDefinedFunction specialize(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context)

createCollectionUnnestFunction

protected abstract 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)

createMapUnnestFunction

protected abstract 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)

getUnnestedType

public static org.apache.flink.table.types.logical.LogicalType getUnnestedType(org.apache.flink.table.types.logical.LogicalType logicalType,
                                                                               boolean withOrdinality)

wrapWithOrdinality

public static org.apache.flink.table.types.logical.LogicalType wrapWithOrdinality(org.apache.flink.table.types.logical.LogicalType baseType)