Uses of Interface
org.apache.flink.table.types.inference.TypeStrategy
-
Packages that use TypeStrategy Package Description org.apache.flink.table.functions org.apache.flink.table.types.inference org.apache.flink.table.types.inference.strategies -
-
Uses of TypeStrategy in org.apache.flink.table.functions
Methods in org.apache.flink.table.functions with parameters of type TypeStrategy Modifier and Type Method Description BuiltInFunctionDefinition.BuilderBuiltInFunctionDefinition.Builder. outputTypeStrategy(TypeStrategy outputTypeStrategy) -
Uses of TypeStrategy in org.apache.flink.table.types.inference
Fields in org.apache.flink.table.types.inference declared as TypeStrategy Modifier and Type Field Description static TypeStrategyTypeStrategies. COMMONType strategy that returns a common, least restrictive type of all arguments.static TypeStrategyTypeStrategies. MISSINGPlaceholder for a missing type strategy.Methods in org.apache.flink.table.types.inference that return TypeStrategy Modifier and Type Method Description static TypeStrategyTypeStrategies. 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 TypeStrategyTypeStrategies. argument(int pos)Type strategy that returns the n-th input argument.static TypeStrategyTypeStrategies. argument(int pos, java.util.function.Function<DataType,Optional<DataType>> mapper)Type strategy that returns the n-th input argument, mapping it.static TypeStrategyTypeStrategies. explicit(DataType dataType)Type strategy that returns a fixedDataType.static TypeStrategyTypeStrategies. first(TypeStrategy... strategies)Type strategy that returns the first type that could be inferred.static TypeStrategyTypeStrategies. forceNullable(TypeStrategy initialStrategy)Type strategy which forces the given {@param initialStrategy} to be nullable.TypeStrategyTypeInference. getOutputTypeStrategy()static TypeStrategyTypeStrategies. mapping(Map<InputTypeStrategy,TypeStrategy> mappings)Type strategy that maps anInputTypeStrategyto aTypeStrategyif the input strategy infers identical types.static TypeStrategyTypeStrategies. matchFamily(int argumentPos, LogicalTypeFamily family)Type strategy that returns the given argument if it is of the same logical type family.static TypeStrategyTypeStrategies. 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 TypeStrategyTypeStrategies. nullableIfAllArgs(TypeStrategy initialStrategy)A type strategy that can be used to make a result type nullable if all the input arguments is nullable.static TypeStrategyTypeStrategies. 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 TypeStrategyTypeStrategies. 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 TypeStrategyTypeStrategies. varyingString(TypeStrategy initialStrategy)A type strategy that ensures that the result type is eitherLogicalTypeRoot.VARCHARorLogicalTypeRoot.VARBINARYfrom their corresponding non-varying roots.Methods in org.apache.flink.table.types.inference that return types with arguments of type TypeStrategy Modifier and Type Method Description Optional<TypeStrategy>TypeInference. getAccumulatorTypeStrategy()Methods in org.apache.flink.table.types.inference with parameters of type TypeStrategy Modifier and Type Method Description TypeInference.BuilderTypeInference.Builder. accumulatorTypeStrategy(TypeStrategy accumulatorTypeStrategy)Sets the strategy for inferring the intermediate accumulator data type of a function call.static TypeStrategyTypeStrategies. first(TypeStrategy... strategies)Type strategy that returns the first type that could be inferred.static TypeStrategyTypeStrategies. forceNullable(TypeStrategy initialStrategy)Type strategy which forces the given {@param initialStrategy} to be nullable.static DataTypeTypeInferenceUtil. inferOutputType(CallContext callContext, TypeStrategy outputTypeStrategy)Infers an output type using the givenTypeStrategy.static TypeStrategyTypeStrategies. 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 TypeStrategyTypeStrategies. nullableIfAllArgs(TypeStrategy initialStrategy)A type strategy that can be used to make a result type nullable if all the input arguments is nullable.static TypeStrategyTypeStrategies. 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 TypeStrategyTypeStrategies. 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.BuilderTypeInference.Builder. outputTypeStrategy(TypeStrategy outputTypeStrategy)Sets the strategy for inferring the final output data type of a function call.static TypeStrategyTypeStrategies. varyingString(TypeStrategy initialStrategy)A type strategy that ensures that the result type is eitherLogicalTypeRoot.VARCHARorLogicalTypeRoot.VARBINARYfrom their corresponding non-varying roots.Method parameters in org.apache.flink.table.types.inference with type arguments of type TypeStrategy Modifier and Type Method Description static TypeStrategyTypeStrategies. mapping(Map<InputTypeStrategy,TypeStrategy> mappings)Type strategy that maps anInputTypeStrategyto aTypeStrategyif the input strategy infers identical types. -
Uses of TypeStrategy in org.apache.flink.table.types.inference.strategies
Classes in org.apache.flink.table.types.inference.strategies that implement TypeStrategy Modifier and Type Class Description classArgumentMappingTypeStrategyType strategy that returns the n-th input argument, mapping it with the provided function.classCommonTypeStrategyType strategy that returns a common, least restrictive type of all arguments.classExplicitTypeStrategyType strategy that returns a fixedDataType.classFirstTypeStrategyType strategy that returns the first type that could be inferred.classForceNullableTypeStrategyForces a given type strategy to be nullable.classHiveAggDecimalPlusTypeStrategyType strategy that returns the result type of a decimal addition, used internally for implementing native SUM/AVG aggregations on a Decimal type.classMappingTypeStrategyType strategy that maps anInputTypeStrategyto aTypeStrategyif the input strategy infers compatible types.classMatchFamilyTypeStrategyType strategy that returns the given argument if it is of the same logical type family.classMissingTypeStrategyPlaceholder for a missing type strategy.classNullableIfArgsTypeStrategyA type strategy that can be used to make a result type nullable if any or all of the selected input arguments are nullable.classToTimestampLtzTypeStrategyType strategy ofTO_TIMESTAMP_LTZ.classVaryingStringTypeStrategyA type strategy that ensures that the result type is eitherLogicalTypeRoot.VARCHARorLogicalTypeRoot.VARBINARYfrom their corresponding non-varying roots.Fields in org.apache.flink.table.types.inference.strategies declared as TypeStrategy Modifier and Type Field Description static TypeStrategySpecificTypeStrategies. AGG_DECIMAL_PLUSSeeAggDecimalPlusTypeStrategy.static TypeStrategySpecificTypeStrategies. ARRAYSeeArrayTypeStrategy.static TypeStrategySpecificTypeStrategies. ARRAY_ELEMENTType strategy specific for array element.static TypeStrategySpecificTypeStrategies. CURRENT_WATERMARKSeeCurrentWatermarkTypeStrategy.static TypeStrategySpecificTypeStrategies. DECIMAL_DIVIDESeeDecimalDivideTypeStrategy.static TypeStrategySpecificTypeStrategies. DECIMAL_MODSeeDecimalModTypeStrategy.static TypeStrategySpecificTypeStrategies. DECIMAL_PLUSSeeDecimalPlusTypeStrategy.static TypeStrategySpecificTypeStrategies. DECIMAL_SCALE_0SeeDecimalScale0TypeStrategy.static TypeStrategySpecificTypeStrategies. DECIMAL_TIMESSeeDecimalTimesTypeStrategy.static TypeStrategySpecificTypeStrategies. GETSeeGetTypeStrategy.static TypeStrategySpecificTypeStrategies. HIVE_AGG_DECIMAL_PLUSstatic TypeStrategySpecificTypeStrategies. IF_NULLSeeIfNullTypeStrategy.static TypeStrategySpecificTypeStrategies. INTERNAL_REPLICATE_ROWSSeeInternalReplicateRowsTypeStrategy.static TypeStrategySpecificTypeStrategies. MAPSeeMapTypeStrategy.static TypeStrategySpecificTypeStrategies. MAP_ENTRIESType strategy specific forBuiltInFunctionDefinitions.MAP_ENTRIES.static TypeStrategySpecificTypeStrategies. MAP_FROM_ARRAYSType strategy specific forBuiltInFunctionDefinitions.MAP_FROM_ARRAYS.static TypeStrategySpecificTypeStrategies. MAP_KEYSType strategy specific forBuiltInFunctionDefinitions.MAP_KEYS.static TypeStrategySpecificTypeStrategies. MAP_VALUESType strategy specific forBuiltInFunctionDefinitions.MAP_VALUES.static TypeStrategySpecificTypeStrategies. ROUNDSeeRoundTypeStrategy.static TypeStrategySpecificTypeStrategies. ROWSeeRowTypeStrategy.static TypeStrategySpecificTypeStrategies. SOURCE_WATERMARKSeeSourceWatermarkTypeStrategy.static TypeStrategySpecificTypeStrategies. STRING_CONCATSeeStringConcatTypeStrategy.static TypeStrategySpecificTypeStrategies. TO_TIMESTAMP_LTZstatic TypeStrategySpecificTypeStrategies. UNUSEDSeeUnusedTypeStrategy.Constructors in org.apache.flink.table.types.inference.strategies with parameters of type TypeStrategy Constructor Description ForceNullableTypeStrategy(TypeStrategy initialStrategy)NullableIfArgsTypeStrategy(ConstantArgumentCount includedArguments, TypeStrategy initialStrategy, boolean nullableIfAllArgsNullable)VaryingStringTypeStrategy(TypeStrategy initialStrategy)Constructor parameters in org.apache.flink.table.types.inference.strategies with type arguments of type TypeStrategy Constructor Description FirstTypeStrategy(List<? extends TypeStrategy> typeStrategies)MappingTypeStrategy(Map<InputTypeStrategy,TypeStrategy> mappings)
-