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:

FunctionDefinition, 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 UnnestTableFunctionBase.

Nested Class Summary

Nested Classes

Modifier and Type	Class and 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

SpecializedFunction.ExpressionEvaluator, SpecializedFunction.ExpressionEvaluatorFactory, SpecializedFunction.SpecializedContext

Constructor Summary

Constructors

Constructor and Description
UnnestRowsFunction()

Method Summary

Modifier and Type	Method and Description
static LogicalType	getUnnestedType(LogicalType logicalType)
UserDefinedFunction	specialize(SpecializedFunction.SpecializedContext context) Provides a runtime implementation that is specialized for the given call and session.

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 UserDefinedFunction specialize(SpecializedFunction.SpecializedContext context)

Description copied from interface: SpecializedFunction

Provides a runtime implementation that is specialized for the given call and session.

The method must return an instance of UserDefinedFunction or throw a TableException if the given call is not supported. The returned instance must have the same FunctionDefinition semantics but can have a different FunctionDefinition.getTypeInference(DataTypeFactory) implementation.

getUnnestedType

public static LogicalType getUnnestedType(LogicalType logicalType)