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 SchemaTranslator.ConsumingResult |
SchemaTranslator.createConsumingResult(DataTypeFactory dataTypeFactory,
DataType inputDataType,
Schema declaredSchema,
boolean mergePhysicalSchema)
Converts the given
DataType and an optional declared Schema (possibly
incomplete) into the final SchemaTranslator.ConsumingResult . |
static SchemaTranslator.ConsumingResult |
SchemaTranslator.createConsumingResult(DataTypeFactory dataTypeFactory,
TypeInformation<?> inputTypeInfo,
Schema declaredSchema)
Converts the given
TypeInformation and an optional declared Schema (possibly
incomplete) into the final SchemaTranslator.ConsumingResult . |
static SchemaTranslator.ProducingResult |
SchemaTranslator.createProducingResult(DataTypeFactory dataTypeFactory,
ResolvedSchema inputSchema,
AbstractDataType<?> targetDataType)
Converts the given
DataType into the final SchemaTranslator.ProducingResult . |
CatalogManager.Builder |
CatalogManager.Builder.dataTypeFactory(DataTypeFactory dataTypeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
InternalRowMergerFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
LastDatedValueFunction.getTypeInference(DataTypeFactory typeFactory)
Declares the
TypeInference of this function. |
Modifier and Type | Method and Description |
---|---|
static ExpressionResolver.ExpressionResolverBuilder |
ExpressionResolver.resolverFor(TableConfig tableConfig,
ClassLoader userClassLoader,
TableReferenceLookup tableCatalog,
FunctionLookup functionLookup,
DataTypeFactory typeFactory,
SqlExpressionResolver sqlExpressionResolver,
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 |
AggregateFunctionDefinition.getTypeInference(DataTypeFactory typeFactory)
Deprecated.
|
abstract TypeInference |
UserDefinedFunction.getTypeInference(DataTypeFactory typeFactory)
Returns the logic for performing type inference of a call to this function definition.
|
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 |
AsyncTableFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
AggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
TableFunctionDefinition.getTypeInference(DataTypeFactory typeFactory)
Deprecated.
|
TypeInference |
ScalarFunctionDefinition.getTypeInference(DataTypeFactory factory)
Deprecated.
|
TypeInference |
ScalarFunction.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
TableAggregateFunctionDefinition.getTypeInference(DataTypeFactory typeFactory)
Deprecated.
|
TypeInference |
BuiltInFunctionDefinition.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
TableAggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
HiveGenericUDAF.getTypeInference(DataTypeFactory typeFactory) |
TypeInference |
HiveGenericUDTF.getTypeInference(DataTypeFactory typeFactory) |
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) |
TypeInference |
PythonTableAggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
static OperationTreeBuilder |
OperationTreeBuilder.create(TableConfig tableConfig,
ClassLoader userClassLoader,
FunctionLookup functionCatalog,
DataTypeFactory typeFactory,
TableReferenceLookup tableReferenceLookup,
SqlExpressionResolver sqlExpressionResolver,
boolean isStreamingMode) |
Constructor and Description |
---|
FunctionCatalogOperatorTable(FunctionCatalog functionCatalog,
DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
RexFactory rexFactory) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.validateSchemaAndApplyImplicitCast(org.apache.calcite.rel.RelNode query,
ResolvedSchema sinkSchema,
String tableDebugName,
DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory)
Checks if the given query can be written into the given sink's table schema.
|
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
CallExpressionConvertRule.ConvertContext.getDataTypeFactory() |
Modifier and Type | Method and Description |
---|---|
TypeInference |
DeclarativeAggregateFunction.getTypeInference(DataTypeFactory factory) |
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
BridgingSqlAggFunction.getDataTypeFactory() |
DataTypeFactory |
BridgingSqlFunction.getDataTypeFactory() |
Modifier and Type | Method and Description |
---|---|
static BridgingSqlFunction |
BridgingSqlFunction.of(DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
RexFactory rexFactory,
org.apache.calcite.sql.SqlKind kind,
ContextResolvedFunction resolvedFunction,
TypeInference typeInference)
Creates an instance of a scalar or table function (either a system or user-defined function).
|
static BridgingSqlAggFunction |
BridgingSqlAggFunction.of(DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
org.apache.calcite.sql.SqlKind kind,
ContextResolvedFunction resolvedFunction,
TypeInference typeInference)
Creates an instance of a aggregating 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,
boolean isGroupedAggregation) |
CallBindingCallContext(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
org.apache.calcite.sql.SqlCallBinding binding,
org.apache.calcite.rel.type.RelDataType outputType) |
LookupCallContext(DataTypeFactory dataTypeFactory,
UserDefinedFunction function,
LogicalType inputType,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
int[] lookupKeyOrder,
LogicalType lookupType) |
OperatorBindingCallContext(DataTypeFactory dataTypeFactory,
FunctionDefinition definition,
org.apache.calcite.sql.SqlOperatorBinding binding,
org.apache.calcite.rel.type.RelDataType returnRelDataType) |
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 |
---|---|
static LogicalType |
LogicalRelDataTypeConverter.toLogicalType(org.apache.calcite.rel.type.RelDataType relDataType,
DataTypeFactory dataTypeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
BuiltInSpecializedFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
BuiltInAggregateFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
BuiltInScalarFunction.getTypeInference(DataTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
TypeInference |
BuiltInTableFunction.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 |
---|---|
Optional<DataType> |
TypeInferenceUtil.SurroundingInfo.inferOutputType(DataTypeFactory typeFactory) |
default DataType |
TypeTransformation.transform(DataTypeFactory factory,
DataType typeToTransform)
Transforms the given data type to a different data type.
|
Modifier and Type | Method and Description |
---|---|
DataType |
LegacyToNonLegacyTransformation.transform(DataTypeFactory factory,
DataType dataType) |
Modifier and Type | Method and Description |
---|---|
DataTypeFactory |
UnknownCallContext.getDataTypeFactory() |
DataTypeFactory |
AdaptedCallContext.getDataTypeFactory() |
Constructor and Description |
---|
UnknownCallContext(DataTypeFactory typeFactory,
String name,
FunctionDefinition functionDefinition,
int argumentCount,
boolean isGroupedAggregation) |
Modifier and Type | Method and Description |
---|---|
static DataType |
TypeInfoDataTypeConverter.toDataType(DataTypeFactory dataTypeFactory,
TypeInformation<?> typeInfo)
Converts the given
TypeInformation into DataType . |
static DataType |
TypeInfoDataTypeConverter.toDataType(DataTypeFactory dataTypeFactory,
TypeInformation<?> typeInfo,
boolean forceNullability)
Converts the given
TypeInformation into DataType but allows to make all
fields nullable independent of the nullability in the serialization stack. |
static DataType |
DataTypeUtils.transform(DataTypeFactory factory,
DataType typeToTransform,
TypeTransformation... transformations)
Transforms the given data type to a different data type using the given transformations.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.