Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.codegen.calls | |
org.apache.flink.table.expressions | |
org.apache.flink.table.functions.utils |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.registerFunction(String name,
ScalarFunction function)
Registers a
ScalarFunction under a unique name. |
Constructor and Description |
---|
ScalarFunctionCallGen(ScalarFunction scalarFunction,
scala.collection.Seq<TypeInformation<?>> signature,
TypeInformation<?> returnType) |
Modifier and Type | Method and Description |
---|---|
ScalarFunction |
ScalarFunctionCall.scalarFunction() |
Constructor and Description |
---|
ScalarFunctionCall(ScalarFunction scalarFunction,
scala.collection.Seq<Expression> parameters) |
Modifier and Type | Method and Description |
---|---|
ScalarFunction |
ScalarSqlFunction.getScalarFunction() |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.sql.type.SqlOperandTypeChecker |
ScalarSqlFunction.createOperandTypeChecker(String name,
ScalarFunction scalarFunction) |
org.apache.calcite.sql.type.SqlOperandTypeChecker |
ScalarSqlFunction$.createOperandTypeChecker(String name,
ScalarFunction scalarFunction) |
static org.apache.calcite.sql.type.SqlOperandTypeInference |
ScalarSqlFunction.createOperandTypeInference(ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
org.apache.calcite.sql.type.SqlOperandTypeInference |
ScalarSqlFunction$.createOperandTypeInference(ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
static org.apache.calcite.sql.type.SqlReturnTypeInference |
ScalarSqlFunction.createReturnTypeInference(String name,
ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
org.apache.calcite.sql.type.SqlReturnTypeInference |
ScalarSqlFunction$.createReturnTypeInference(String name,
ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
static org.apache.calcite.sql.SqlFunction |
UserDefinedFunctionUtils.createScalarSqlFunction(String name,
ScalarFunction function,
FlinkTypeFactory typeFactory)
Create
SqlFunction for a ScalarFunction |
org.apache.calcite.sql.SqlFunction |
UserDefinedFunctionUtils$.createScalarSqlFunction(String name,
ScalarFunction function,
FlinkTypeFactory typeFactory)
Create
SqlFunction for a ScalarFunction |
static Class<?> |
UserDefinedFunctionUtils.getResultTypeClassOfScalarFunction(ScalarFunction function,
Class<?>[] signature)
Returns the return type of the evaluation method matching the given signature.
|
Class<?> |
UserDefinedFunctionUtils$.getResultTypeClassOfScalarFunction(ScalarFunction function,
Class<?>[] signature)
Returns the return type of the evaluation method matching the given signature.
|
static TypeInformation<?> |
UserDefinedFunctionUtils.getResultTypeOfScalarFunction(ScalarFunction function,
Class<?>[] signature)
Internal method of
ScalarFunction#getResultType() that does some pre-checking and uses
TypeExtractor as default return type inference. |
TypeInformation<?> |
UserDefinedFunctionUtils$.getResultTypeOfScalarFunction(ScalarFunction function,
Class<?>[] signature)
Internal method of
ScalarFunction#getResultType() that does some pre-checking and uses
TypeExtractor as default return type inference. |
Constructor and Description |
---|
ScalarSqlFunction(String name,
ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.