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

Class UnnestRowsFunction

java.lang.Object

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

org.apache.flink.table.runtime.functions.table.UnnestRowsFunction

All Implemented Interfaces:

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

@Internal
public class UnnestRowsFunction
extends BuiltInSpecializedFunction

Flattens ARRAY, MAP, and MULTISET using a table function. It does this by another level of specialization using a subclass of UnnestRowsFunction.UnnestTableFunctionBase.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	UnnestRowsFunction.CollectionUnnestTableFunction	Table function that unwraps the elements of a collection (array or multiset).
static class	UnnestRowsFunction.MapUnnestTableFunction	Table function that unwraps the elements of a map.

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
UnnestRowsFunction()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.types.logical.LogicalType	getUnnestedType(org.apache.flink.table.types.logical.LogicalType logicalType)
org.apache.flink.table.functions.UserDefinedFunction	specialize(org.apache.flink.table.functions.SpecializedFunction.SpecializedContext context)

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

Constructor Detail

UnnestRowsFunction

public UnnestRowsFunction()

Method Detail

specialize

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

getUnnestedType

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