Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.expressions | |
org.apache.flink.table.functions | |
org.apache.flink.table.planner.functions.utils |
Modifier and Type | Method and Description |
---|---|
Optional<FunctionIdentifier> |
ContextResolvedFunction.getIdentifier() |
Modifier and Type | Method and Description |
---|---|
static ContextResolvedFunction |
ContextResolvedFunction.permanent(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition) |
static ContextResolvedFunction |
ContextResolvedFunction.temporary(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition) |
Modifier and Type | Method and Description |
---|---|
Optional<FunctionIdentifier> |
UnresolvedCallExpression.getFunctionIdentifier() |
Optional<FunctionIdentifier> |
CallExpression.getFunctionIdentifier() |
Modifier and Type | Method and Description |
---|---|
static CallExpression |
CallExpression.permanent(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
|
static CallExpression |
CallExpression.temporary(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
Creates a
CallExpression to a temporary function (potentially shadowing a Catalog function or providing a system function). |
Constructor and Description |
---|
CallExpression(boolean isTemporary,
FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType) |
CallExpression(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType)
|
Modifier and Type | Method and Description |
---|---|
static FunctionIdentifier |
FunctionIdentifier.of(ObjectIdentifier oi) |
static FunctionIdentifier |
FunctionIdentifier.of(String functionName) |
Constructor and Description |
---|
HiveAggSqlFunction(FunctionIdentifier identifier,
AggregateFunction aggregateFunction,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory)
Deprecated.
|
HiveTableSqlFunction(FunctionIdentifier identifier,
TableFunction hiveUdtf,
DataType implicitResultType,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
org.apache.flink.table.planner.plan.schema.FlinkTableFunction functionImpl,
HiveTableSqlFunction.HiveOperandTypeChecker operandTypeChecker)
Deprecated.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.