Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
CatalogManager.getDataTypeFactory()
Returns a factory for creating fully resolved data types that can be used for planning.
|
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableConfig config,
TableReferenceLookup tableCatalog,
FunctionLookup functionLookup,
DataTypeFactory typeFactory,
QueryOperation... inputs)
Creates a builder for
ExpressionResolver . |
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
ResolverRule.ResolutionContext.typeFactory()
Access to
DataTypeFactory . |
Modifier and Type | Method and Description |
---|---|
TypeInference |
TemporalTableFunctionImpl.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
ScalarFunctionDefinition.getTypeInference(DataTypeFactory factory) |
TypeInference |
TableAggregateFunctionDefinition.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
TableAggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
abstract TypeInference |
UserDefinedFunction.getTypeInference(DataTypeFactory typeFactory)
Returns the logic for performing type inference of a call to this function definition.
|
TypeInference |
AsyncTableFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
AggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
AggregateFunctionDefinition.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
ScalarFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
TableFunctionDefinition.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
FunctionDefinition.getTypeInference(DataTypeFactory typeFactory)
Returns the logic for performing type inference of a call to this function definition.
|
TypeInference |
TableFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
BuiltInFunctionDefinition.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
HiveScalarFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
PythonScalarFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
PythonTableFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
PythonAggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
static OperationTreeBuilder |
OperationTreeBuilder.create(TableConfig config,
FunctionLookup functionCatalog,
DataTypeFactory typeFactory,
TableReferenceLookup tableReferenceLookup,
boolean isStreamingMode) |
Constructor and Description |
---|
FunctionCatalogOperatorTable(FunctionCatalog functionCatalog,
DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
CallExpressionConvertRule.ConvertContext.getDataTypeFactory() |
Modifier and Type | Method and Description |
---|---|
TypeInference |
DeclarativeAggregateFunction.getTypeInference(DataTypeFactory factory) |
TypeInference |
InternalAggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
BridgingSqlAggFunction.getDataTypeFactory() |
DataTypeFactory |
BridgingSqlFunction.getDataTypeFactory() |
Modifier and Type | Method and Description |
---|---|
static BridgingSqlAggFunction |
BridgingSqlAggFunction.of(DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
org.apache.calcite.sql.SqlKind kind,
FunctionIdentifier identifier,
FunctionDefinition definition,
TypeInference typeInference)
Creates an instance of a aggregating function (either a system or user-defined function).
|
static BridgingSqlFunction |
BridgingSqlFunction.of(DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
org.apache.calcite.sql.SqlKind kind,
FunctionIdentifier identifier,
FunctionDefinition definition,
TypeInference typeInference)
Creates an instance of a scalar or table function (either a system or user-defined function).
|
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
AbstractSqlCallContext.getDataTypeFactory() |
Constructor and Description |
---|
AbstractSqlCallContext(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
String name) |
CallBindingCallContext(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
org.apache.calcite.sql.SqlCallBinding binding,
org.apache.calcite.rel.type.RelDataType outputType) |
OperatorBindingCallContext(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
org.apache.calcite.sql.SqlOperatorBinding binding) |
TypeInferenceOperandChecker(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
TypeInference typeInference) |
TypeInferenceOperandInference(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
TypeInference typeInference) |
TypeInferenceReturnInference(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
TypeInference typeInference) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
SqlUnnestUtils.UnnestTableFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
DataType |
UnresolvedDataType.toDataType(DataTypeFactory factory)
Converts this instance to a resolved
DataType possibly enriched with additional
nullability and conversion class information. |
Constructor and Description |
---|
UnresolvedDataType(java.util.function.Supplier<String> description,
java.util.function.Function<DataTypeFactory,DataType> resolutionFactory) |
Modifier and Type | Method and Description |
---|---|
static DataType |
DataTypeExtractor.extractFromGeneric(DataTypeFactory typeFactory,
Class<?> baseClass,
int genericPos,
Type contextType)
Extracts a data type from a type variable at
genericPos of baseClass using
the information of the most specific type contextType . |
static DataType |
DataTypeExtractor.extractFromMethodOutput(DataTypeFactory typeFactory,
Class<?> baseClass,
Method method)
Extracts a data type from a method return type by considering surrounding classes and method
annotation.
|
static DataType |
DataTypeExtractor.extractFromMethodParameter(DataTypeFactory typeFactory,
Class<?> baseClass,
Method method,
int paramPos)
Extracts a data type from a method parameter by considering surrounding classes and parameter
annotation.
|
static DataType |
DataTypeExtractor.extractFromType(DataTypeFactory typeFactory,
org.apache.flink.table.types.extraction.DataTypeTemplate template,
Type type)
Extracts a data type from a type without considering surrounding classes but templates.
|
static DataType |
DataTypeExtractor.extractFromType(DataTypeFactory typeFactory,
Type type)
Extracts a data type from a type without considering surrounding classes or templates.
|
static TypeInference |
TypeInferenceExtractor.forAggregateFunction(DataTypeFactory typeFactory,
Class<? extends AggregateFunction<?,?>> function)
Extracts a type inference from a
AggregateFunction . |
static TypeInference |
TypeInferenceExtractor.forAsyncTableFunction(DataTypeFactory typeFactory,
Class<? extends AsyncTableFunction<?>> function)
Extracts a type inference from a
AsyncTableFunction . |
static TypeInference |
TypeInferenceExtractor.forScalarFunction(DataTypeFactory typeFactory,
Class<? extends ScalarFunction> function)
Extracts a type inference from a
ScalarFunction . |
static TypeInference |
TypeInferenceExtractor.forTableAggregateFunction(DataTypeFactory typeFactory,
Class<? extends TableAggregateFunction<?,?>> function)
Extracts a type inference from a
TableAggregateFunction . |
static TypeInference |
TypeInferenceExtractor.forTableFunction(DataTypeFactory typeFactory,
Class<? extends TableFunction<?>> function)
Extracts a type inference from a
TableFunction . |
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
CallContext.getDataTypeFactory()
Enables to lookup types in a catalog and resolve RAW types.
|
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
UnknownCallContext.getDataTypeFactory() |
DataTypeFactory |
AdaptedCallContext.getDataTypeFactory() |
Constructor and Description |
---|
UnknownCallContext(DataTypeFactory typeFactory,
String name,
FunctionDefinition functionDefinition,
int argumentCount) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.