Package | Description |
---|---|
org.apache.flink.table.functions | |
org.apache.flink.table.functions.hive | |
org.apache.flink.table.types.inference | |
org.apache.flink.table.types.inference.strategies |
Modifier and Type | Method and Description |
---|---|
BuiltInFunctionDefinition.Builder |
BuiltInFunctionDefinition.Builder.outputTypeStrategy(TypeStrategy outputTypeStrategy) |
Modifier and Type | Class and Description |
---|---|
static class |
HiveFunction.HiveFunctionOutputStrategy
OutputTypeStrategy for Hive UDF, UDTF, UDAF.
|
Modifier and Type | Field and Description |
---|---|
static TypeStrategy |
TypeStrategies.COMMON
Type strategy that returns a common, least restrictive type of all arguments.
|
static TypeStrategy |
TypeStrategies.MISSING
Placeholder for a missing type strategy.
|
Modifier and Type | Method and Description |
---|---|
static TypeStrategy |
TypeStrategies.aggArg0(java.util.function.Function<LogicalType,LogicalType> aggType,
boolean nullableIfGroupingEmpty)
Type strategy specific for aggregations that partially produce different nullability
depending whether the result is grouped or not.
|
static TypeStrategy |
TypeStrategies.argument(int pos)
Type strategy that returns the n-th input argument.
|
static TypeStrategy |
TypeStrategies.argument(int pos,
java.util.function.Function<DataType,Optional<DataType>> mapper)
Type strategy that returns the n-th input argument, mapping it.
|
static TypeStrategy |
TypeStrategies.explicit(DataType dataType)
Type strategy that returns a fixed
DataType . |
static TypeStrategy |
TypeStrategies.first(TypeStrategy... strategies)
Type strategy that returns the first type that could be inferred.
|
static TypeStrategy |
TypeStrategies.forceNullable(TypeStrategy initialStrategy)
Type strategy which forces the given to be nullable.
|
TypeStrategy |
TypeInference.getOutputTypeStrategy() |
static TypeStrategy |
TypeStrategies.mapping(Map<InputTypeStrategy,TypeStrategy> mappings)
Type strategy that maps an
InputTypeStrategy to a TypeStrategy if the input
strategy infers identical types. |
static TypeStrategy |
TypeStrategies.matchFamily(int argumentPos,
LogicalTypeFamily family)
Type strategy that returns the given argument if it is of the same logical type family.
|
static TypeStrategy |
TypeStrategies.nullableIfAllArgs(ConstantArgumentCount includedArgs,
TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if all the selected input
arguments are nullable.
|
static TypeStrategy |
TypeStrategies.nullableIfAllArgs(TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if all the input arguments is
nullable.
|
static TypeStrategy |
TypeStrategies.nullableIfArgs(ConstantArgumentCount includedArgs,
TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if any of the selected input
arguments is nullable.
|
static TypeStrategy |
TypeStrategies.nullableIfArgs(TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if any of the input arguments
is nullable.
|
static TypeStrategy |
TypeStrategies.varyingString(TypeStrategy initialStrategy)
A type strategy that ensures that the result type is either
LogicalTypeRoot.VARCHAR
or LogicalTypeRoot.VARBINARY from their corresponding non-varying roots. |
Modifier and Type | Method and Description |
---|---|
Optional<TypeStrategy> |
TypeInference.getAccumulatorTypeStrategy() |
Modifier and Type | Method and Description |
---|---|
TypeInference.Builder |
TypeInference.Builder.accumulatorTypeStrategy(TypeStrategy accumulatorTypeStrategy)
Sets the strategy for inferring the intermediate accumulator data type of a function
call.
|
static TypeStrategy |
TypeStrategies.first(TypeStrategy... strategies)
Type strategy that returns the first type that could be inferred.
|
static TypeStrategy |
TypeStrategies.forceNullable(TypeStrategy initialStrategy)
Type strategy which forces the given to be nullable.
|
static DataType |
TypeInferenceUtil.inferOutputType(CallContext callContext,
TypeStrategy outputTypeStrategy)
Infers an output type using the given
TypeStrategy . |
static TypeStrategy |
TypeStrategies.nullableIfAllArgs(ConstantArgumentCount includedArgs,
TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if all the selected input
arguments are nullable.
|
static TypeStrategy |
TypeStrategies.nullableIfAllArgs(TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if all the input arguments is
nullable.
|
static TypeStrategy |
TypeStrategies.nullableIfArgs(ConstantArgumentCount includedArgs,
TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if any of the selected input
arguments is nullable.
|
static TypeStrategy |
TypeStrategies.nullableIfArgs(TypeStrategy initialStrategy)
A type strategy that can be used to make a result type nullable if any of the input arguments
is nullable.
|
TypeInference.Builder |
TypeInference.Builder.outputTypeStrategy(TypeStrategy outputTypeStrategy)
Sets the strategy for inferring the final output data type of a function call.
|
static TypeStrategy |
TypeStrategies.varyingString(TypeStrategy initialStrategy)
A type strategy that ensures that the result type is either
LogicalTypeRoot.VARCHAR
or LogicalTypeRoot.VARBINARY from their corresponding non-varying roots. |
Modifier and Type | Method and Description |
---|---|
static TypeStrategy |
TypeStrategies.mapping(Map<InputTypeStrategy,TypeStrategy> mappings)
Type strategy that maps an
InputTypeStrategy to a TypeStrategy if the input
strategy infers identical types. |
Modifier and Type | Class and Description |
---|---|
class |
ArgumentMappingTypeStrategy
Type strategy that returns the n-th input argument, mapping it with the provided function.
|
class |
CommonTypeStrategy
Type strategy that returns a common, least restrictive type of all arguments.
|
class |
ExplicitTypeStrategy
Type strategy that returns a fixed
DataType . |
class |
FirstTypeStrategy
Type strategy that returns the first type that could be inferred.
|
class |
ForceNullableTypeStrategy
Forces a given type strategy to be nullable.
|
class |
MappingTypeStrategy
Type strategy that maps an
InputTypeStrategy to a TypeStrategy if the input
strategy infers compatible types. |
class |
MatchFamilyTypeStrategy
Type strategy that returns the given argument if it is of the same logical type family.
|
class |
MissingTypeStrategy
Placeholder for a missing type strategy.
|
class |
NullableIfArgsTypeStrategy
A type strategy that can be used to make a result type nullable if any or all of the selected
input arguments are nullable.
|
class |
ToTimestampLtzTypeStrategy
Type strategy of
TO_TIMESTAMP_LTZ . |
class |
VaryingStringTypeStrategy
A type strategy that ensures that the result type is either
LogicalTypeRoot.VARCHAR or
LogicalTypeRoot.VARBINARY from their corresponding non-varying roots. |
Modifier and Type | Field and Description |
---|---|
static TypeStrategy |
SpecificTypeStrategies.AGG_DECIMAL_PLUS
See
AggDecimalPlusTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.ARRAY
See
ArrayTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.CURRENT_WATERMARK
See
CurrentWatermarkTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.DECIMAL_DIVIDE
See
DecimalDivideTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.DECIMAL_MOD
See
DecimalModTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.DECIMAL_PLUS
See
DecimalPlusTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.DECIMAL_SCALE_0
See
DecimalScale0TypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.DECIMAL_TIMES
See
DecimalTimesTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.GET
See
GetTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.IF_NULL
See
IfNullTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.INTERNAL_REPLICATE_ROWS
See
InternalReplicateRowsTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.MAP
See
MapTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.ROUND
See
RoundTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.ROW
See
RowTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.SOURCE_WATERMARK
See
SourceWatermarkTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.STRING_CONCAT
See
StringConcatTypeStrategy . |
static TypeStrategy |
SpecificTypeStrategies.TO_TIMESTAMP_LTZ
|
Constructor and Description |
---|
ForceNullableTypeStrategy(TypeStrategy initialStrategy) |
NullableIfArgsTypeStrategy(ConstantArgumentCount includedArguments,
TypeStrategy initialStrategy,
boolean nullableIfAllArgsNullable) |
VaryingStringTypeStrategy(TypeStrategy initialStrategy) |
Constructor and Description |
---|
FirstTypeStrategy(List<? extends TypeStrategy> typeStrategies) |
MappingTypeStrategy(Map<InputTypeStrategy,TypeStrategy> mappings) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.