Modifier and Type | Method and Description |
---|---|
DataType |
HiveTableSink.getConsumedDataType() |
DataType |
HiveTableSource.getProducedDataType() |
Constructor and Description |
---|
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf,
List<String> partitionKeys,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split,
HiveShim hiveShim) |
HiveVectorizedOrcSplitReader(String hiveVersion,
org.apache.hadoop.mapred.JobConf jobConf,
String[] fieldNames,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split) |
Modifier and Type | Method and Description |
---|---|
static OrcColumnarRowSplitReader |
OrcSplitReaderUtil.genPartColumnarRowReader(String hiveVersion,
Configuration conf,
String[] fullFieldNames,
DataType[] fullFieldTypes,
Map<String,Object> partitionSpec,
int[] selectedFields,
List<OrcSplitReader.Predicate> conjunctPredicates,
int batchSize,
Path path,
long splitStart,
long splitLength)
Util for generating partitioned
OrcColumnarRowSplitReader . |
Modifier and Type | Method and Description |
---|---|
DataType |
BatchSQLTestProgram.GeneratorTableSource.getProducedDataType() |
Modifier and Type | Method and Description |
---|---|
static <T> DataType |
DataTypes.ANY(Class<T> clazz,
TypeSerializer<T> serializer)
Deprecated.
Use
DataTypes.RAW(Class, TypeSerializer) instead. |
static <T> DataType |
DataTypes.ANY(TypeInformation<T> typeInformation)
Deprecated.
Use
DataTypes.RAW(TypeInformation) instead. |
static DataType |
DataTypes.ARRAY(DataType elementDataType)
Data type of an array of elements with same subtype.
|
static DataType |
DataTypes.BIGINT()
Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to
9,223,372,036,854,775,807.
|
static DataType |
DataTypes.BINARY(int n)
Data type of a fixed-length binary string (=a sequence of bytes)
BINARY(n) where
n is the number of bytes. |
static DataType |
DataTypes.BOOLEAN()
Data type of a boolean with a (possibly) three-valued logic of
TRUE, FALSE, UNKNOWN . |
static DataType |
DataTypes.BYTES()
Data type of a variable-length binary string (=a sequence of bytes) with defined maximum length.
|
static DataType |
DataTypes.CHAR(int n)
Data type of a fixed-length character string
CHAR(n) where n is the number
of code points. |
static DataType |
DataTypes.DATE()
Data type of a date consisting of
year-month-day with values ranging from 0000-01-01
to 9999-12-31 . |
static DataType |
DataTypes.DECIMAL(int precision,
int scale)
Data type of a decimal number with fixed precision and scale
DECIMAL(p, s) where p
is the number of digits in a number (=precision) and s is the number of digits to the
right of the decimal point in a number (=scale). |
static DataType |
DataTypes.DOUBLE()
Data type of an 8-byte double precision floating point number.
|
static DataType |
DataTypes.FLOAT()
Data type of a 4-byte single precision floating point number.
|
DataType |
DataTypes.Field.getDataType() |
DataType[] |
TableSchema.getFieldDataTypes()
Returns all field data types as an array.
|
DataType |
TableColumn.getType()
Returns data type of this column.
|
DataType |
WatermarkSpec.getWatermarkExprOutputType()
Returns the data type of the computation result of watermark generation expression.
|
static DataType |
DataTypes.INT()
Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
|
static DataType |
DataTypes.INTERVAL(DataTypes.Resolution resolution)
Data type of a temporal interval.
|
static DataType |
DataTypes.INTERVAL(DataTypes.Resolution upperResolution,
DataTypes.Resolution lowerResolution)
Data type of a temporal interval.
|
static DataType |
DataTypes.MAP(DataType keyDataType,
DataType valueDataType)
Data type of an associative array that maps keys (including
NULL ) to values (including
NULL ). |
static DataType |
DataTypes.MULTISET(DataType elementDataType)
Data type of a multiset (=bag).
|
static DataType |
DataTypes.NULL()
Data type for representing untyped
NULL values. |
static <T> DataType |
DataTypes.RAW(Class<T> clazz,
TypeSerializer<T> serializer)
Data type of an arbitrary serialized type.
|
static <T> DataType |
DataTypes.RAW(TypeInformation<T> typeInformation)
Data type of an arbitrary serialized type backed by
TypeInformation . |
static DataType |
DataTypes.ROW(DataTypes.Field... fields)
Data type of a sequence of fields.
|
static DataType |
DataTypes.SMALLINT()
Data type of a 2-byte signed integer with values from -32,768 to 32,767.
|
static DataType |
DataTypes.STRING()
Data type of a variable-length character string with defined maximum length.
|
static DataType |
DataTypes.TIME()
Data type of a time WITHOUT time zone
TIME with no fractional seconds by default. |
static DataType |
DataTypes.TIME(int precision)
Data type of a time WITHOUT time zone
TIME(p) where p is the number of digits
of fractional seconds (=precision). |
static DataType |
DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE()
Data type of a timestamp WITH LOCAL time zone
TIMESTAMP WITH LOCAL TIME ZONE with 6 digits
of fractional seconds by default. |
static DataType |
DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE(int precision)
Data type of a timestamp WITH LOCAL time zone
TIMESTAMP(p) WITH LOCAL TIME ZONE where
p is the number of digits of fractional seconds (=precision). |
static DataType |
DataTypes.TIMESTAMP_WITH_TIME_ZONE()
Data type of a timestamp WITH time zone
TIMESTAMP WITH TIME ZONE with 6 digits of fractional
seconds by default. |
static DataType |
DataTypes.TIMESTAMP_WITH_TIME_ZONE(int precision)
Data type of a timestamp WITH time zone
TIMESTAMP(p) WITH TIME ZONE where p is
the number of digits of fractional seconds (=precision). |
static DataType |
DataTypes.TIMESTAMP()
Data type of a timestamp WITHOUT time zone
TIMESTAMP with 6 digits of fractional seconds
by default. |
static DataType |
DataTypes.TIMESTAMP(int precision)
Data type of a timestamp WITHOUT time zone
TIMESTAMP(p) where p is the number
of digits of fractional seconds (=precision). |
static DataType |
DataTypes.TINYINT()
Data type of a 1-byte signed integer with values from -128 to 127.
|
DataType |
TableSchema.toRowDataType()
Converts a table schema into a (nested) data type describing a
DataTypes.ROW(Field...) . |
static DataType |
DataTypes.VARBINARY(int n)
Data type of a variable-length binary string (=a sequence of bytes)
VARBINARY(n) where
n is the maximum number of bytes. |
static DataType |
DataTypes.VARCHAR(int n)
Data type of a variable-length character string
VARCHAR(n) where n is the
maximum number of code points. |
Modifier and Type | Method and Description |
---|---|
Optional<DataType> |
TableSchema.getFieldDataType(int fieldIndex)
Returns the specified data type for the given field index.
|
Optional<DataType> |
TableSchema.getFieldDataType(String fieldName)
Returns the specified data type for the given field name.
|
Modifier and Type | Method and Description |
---|---|
static DataType |
DataTypes.ARRAY(DataType elementDataType)
Data type of an array of elements with same subtype.
|
TableSchema.Builder |
TableSchema.Builder.field(String name,
DataType dataType)
Add a field with name and data type.
|
static DataTypes.Field |
DataTypes.FIELD(String name,
DataType dataType)
Field definition with field name and data type.
|
TableSchema.Builder |
TableSchema.Builder.field(String name,
DataType dataType,
String expression)
Add a computed field which is generated by the given expression.
|
static DataTypes.Field |
DataTypes.FIELD(String name,
DataType dataType,
String description)
Field definition with field name, data type, and a description.
|
TableSchema.Builder |
TableSchema.Builder.fields(String[] names,
DataType[] dataTypes)
Add an array of fields with names and data types.
|
static DataType |
DataTypes.MAP(DataType keyDataType,
DataType valueDataType)
Data type of an associative array that maps keys (including
NULL ) to values (including
NULL ). |
static DataType |
DataTypes.MULTISET(DataType elementDataType)
Data type of a multiset (=bag).
|
static TableColumn |
TableColumn.of(String name,
DataType type)
Creates a table column from given name and data type.
|
static TableColumn |
TableColumn.of(String name,
DataType type,
String expression)
Creates a table column from given name and computation expression.
|
TableSchema.Builder |
TableSchema.Builder.watermark(String rowtimeAttribute,
String watermarkExpressionString,
DataType watermarkExprOutputType)
Specifies the previously defined field as an event-time attribute and specifies the watermark strategy.
|
Constructor and Description |
---|
WatermarkSpec(String rowtimeAttribute,
String watermarkExpressionString,
DataType watermarkExprOutputType) |
Modifier and Type | Method and Description |
---|---|
DataType |
DataTypeLookup.resolveRawDataType(Class<?> clazz)
Resolves a RAW type for the given class.
|
Modifier and Type | Method and Description |
---|---|
Optional<DataType> |
DataTypeLookup.lookupDataType(String name)
Lookup a type by a fully or partially defined name.
|
Optional<DataType> |
DataTypeLookup.lookupDataType(UnresolvedIdentifier identifier)
Lookup a type by an unresolved identifier.
|
Modifier and Type | Method and Description |
---|---|
static DataType |
HiveTypeUtil.toFlinkType(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector)
Convert a Hive ObjectInspector to a Flink data type.
|
static DataType |
HiveTypeUtil.toFlinkType(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo hiveType)
Convert Hive data type to a Flink data type.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo |
HiveTypeUtil.toHiveTypeInfo(DataType dataType,
boolean checkPrecision)
Convert Flink DataType to Hive TypeInfo.
|
Modifier and Type | Method and Description |
---|---|
static String[] |
CliUtils.typesToString(DataType[] types) |
Modifier and Type | Method and Description |
---|---|
DataType |
CollectBatchTableSink.getConsumedDataType() |
Modifier and Type | Method and Description |
---|---|
static DataFormatConverters.DataFormatConverter |
DataFormatConverters.getConverterForDataType(DataType originDataType)
|
Constructor and Description |
---|
AbstractBaseRowConverter(DataType[] fieldTypes) |
CaseClassConverter(TupleTypeInfoBase t,
DataType[] fieldTypes) |
MapConverter(DataType keyTypeInfo,
DataType valueTypeInfo) |
ObjectArrayConverter(DataType elementType) |
PojoConverter(PojoTypeInfo<T> t,
DataType[] fieldTypes) |
RowConverter(DataType[] fieldTypes) |
TupleConverter(Class<Tuple> clazz,
DataType[] fieldTypes) |
Modifier and Type | Method and Description |
---|---|
DataType |
DescriptorProperties.getDataType(String key)
Returns the DataType under the given existing key.
|
Modifier and Type | Method and Description |
---|---|
Optional<DataType> |
DescriptorProperties.getOptionalDataType(String key)
Returns the DataType under the given key if it exists.
|
Modifier and Type | Method and Description |
---|---|
OldCsv |
OldCsv.field(String fieldName,
DataType fieldType)
Deprecated.
Adds a format field with the field name and the type information.
|
Schema |
Schema.field(String fieldName,
DataType fieldType)
Adds a field with the field name and the data type.
|
Modifier and Type | Method and Description |
---|---|
DataType |
LocalReferenceExpression.getOutputDataType() |
DataType |
TableReferenceExpression.getOutputDataType() |
DataType |
TypeLiteralExpression.getOutputDataType() |
DataType |
CallExpression.getOutputDataType() |
DataType |
ResolvedExpression.getOutputDataType()
Returns the data type of the computation result.
|
DataType |
FieldReferenceExpression.getOutputDataType() |
DataType |
ValueLiteralExpression.getOutputDataType() |
Modifier and Type | Method and Description |
---|---|
CallExpression |
UnresolvedCallExpression.resolve(List<ResolvedExpression> args,
DataType dataType) |
Constructor and Description |
---|
CallExpression(FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType) |
CallExpression(FunctionIdentifier functionIdentifier,
FunctionDefinition functionDefinition,
List<ResolvedExpression> args,
DataType dataType) |
FieldReferenceExpression(String name,
DataType dataType,
int inputIndex,
int fieldIndex) |
LocalReferenceExpression(String name,
DataType dataType) |
TypeLiteralExpression(DataType dataType) |
ValueLiteralExpression(Object value,
DataType dataType) |
Modifier and Type | Method and Description |
---|---|
CallExpression |
ExpressionResolver.PostResolverFactory.cast(ResolvedExpression expression,
DataType dataType) |
CallExpression |
ExpressionResolver.PostResolverFactory.get(ResolvedExpression composite,
ValueLiteralExpression key,
DataType dataType) |
Modifier and Type | Method and Description |
---|---|
static TypeLiteralExpression |
ApiExpressionUtils.typeLiteral(DataType dataType) |
static ValueLiteralExpression |
ApiExpressionUtils.valueLiteral(Object value,
DataType dataType) |
Modifier and Type | Method and Description |
---|---|
BuiltInFunctionDefinition.Builder |
BuiltInFunctionDefinition.Builder.typedArguments(List<DataType> argumentTypes) |
Modifier and Type | Field and Description |
---|---|
protected DataType[] |
HiveScalarFunction.argTypes |
Modifier and Type | Method and Description |
---|---|
DataType |
HiveSimpleUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveFunction.getHiveResultType(Object[] constantArguments,
DataType[] argTypes)
Get result type by arguments and argTypes.
|
DataType |
HiveGenericUDTF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveGenericUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveGenericUDAF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
Modifier and Type | Method and Description |
---|---|
DataType |
HiveSimpleUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveFunction.getHiveResultType(Object[] constantArguments,
DataType[] argTypes)
Get result type by arguments and argTypes.
|
DataType |
HiveGenericUDTF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveGenericUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveGenericUDAF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
void |
HiveScalarFunction.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes) |
void |
HiveFunction.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes)
Set arguments and argTypes for Function instance.
|
void |
HiveGenericUDTF.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes) |
void |
HiveGenericUDAF.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
HiveInspectors.getObjectInspector(DataType flinkType)
Get Hive
ObjectInspector for a Flink DataType . |
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] |
HiveInspectors.toInspectors(HiveShim hiveShim,
Object[] args,
DataType[] argTypes)
Get an array of ObjectInspector from the give array of args and their types.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
HiveFunctionUtil.isSingleBoxedArray(DataType[] argTypes) |
Modifier and Type | Method and Description |
---|---|
DataType |
OutputConversionModifyOperation.getType() |
Constructor and Description |
---|
OutputConversionModifyOperation(QueryOperation child,
DataType type,
OutputConversionModifyOperation.UpdateMode updateMode) |
Modifier and Type | Method and Description |
---|---|
DataType |
RexNodeExpression.getOutputDataType() |
Modifier and Type | Method and Description |
---|---|
static ValueLiteralExpression |
ExpressionBuilder.literal(Object value,
DataType type) |
static ValueLiteralExpression |
ExpressionBuilder.nullOf(DataType type) |
static TypeLiteralExpression |
ExpressionBuilder.typeLiteral(DataType type) |
Constructor and Description |
---|
RexNodeExpression(org.apache.calcite.rex.RexNode rexNode,
DataType outputDataType) |
Modifier and Type | Method and Description |
---|---|
DataType[] |
RankAggFunction.getAggBufferTypes() |
DataType[] |
DenseRankAggFunction.getAggBufferTypes() |
DataType[] |
Sum0AggFunction.getAggBufferTypes() |
DataType[] |
SingleValueAggFunction.getAggBufferTypes() |
DataType[] |
IncrSumAggFunction.getAggBufferTypes() |
DataType[] |
RowNumberAggFunction.getAggBufferTypes() |
DataType[] |
SumAggFunction.getAggBufferTypes() |
DataType[] |
Count1AggFunction.getAggBufferTypes() |
DataType[] |
LeadLagAggFunction.getAggBufferTypes() |
DataType[] |
AvgAggFunction.getAggBufferTypes() |
DataType[] |
CountAggFunction.getAggBufferTypes() |
DataType[] |
MinAggFunction.getAggBufferTypes() |
DataType[] |
SumWithRetractAggFunction.getAggBufferTypes() |
DataType[] |
IncrSumWithRetractAggFunction.getAggBufferTypes() |
DataType[] |
ListAggFunction.getAggBufferTypes() |
DataType[] |
MaxAggFunction.getAggBufferTypes() |
abstract DataType[] |
DeclarativeAggregateFunction.getAggBufferTypes()
All types of the aggregate buffer.
|
DataType |
Sum0AggFunction.IntSum0AggFunction.getResultType() |
DataType |
Sum0AggFunction.ByteSum0AggFunction.getResultType() |
DataType |
Sum0AggFunction.ShortSum0AggFunction.getResultType() |
DataType |
Sum0AggFunction.LongSum0AggFunction.getResultType() |
DataType |
Sum0AggFunction.FloatSum0AggFunction.getResultType() |
DataType |
Sum0AggFunction.DoubleSum0AggFunction.getResultType() |
DataType |
Sum0AggFunction.DecimalSum0AggFunction.getResultType() |
DataType |
SingleValueAggFunction.ByteSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.ShortSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.IntSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.LongSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.FloatSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.DoubleSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.BooleanSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.DecimalSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.StringSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.DateSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.TimeSingleValueAggFunction.getResultType() |
DataType |
SingleValueAggFunction.TimestampSingleValueAggFunction.getResultType() |
DataType |
IncrSumAggFunction.IntIncrSumAggFunction.getResultType() |
DataType |
IncrSumAggFunction.ByteIncrSumAggFunction.getResultType() |
DataType |
IncrSumAggFunction.ShortIncrSumAggFunction.getResultType() |
DataType |
IncrSumAggFunction.LongIncrSumAggFunction.getResultType() |
DataType |
IncrSumAggFunction.FloatIncrSumAggFunction.getResultType() |
DataType |
IncrSumAggFunction.DoubleIncrSumAggFunction.getResultType() |
DataType |
IncrSumAggFunction.DecimalIncrSumAggFunction.getResultType() |
DataType |
RowNumberAggFunction.getResultType() |
DataType |
SumAggFunction.IntSumAggFunction.getResultType() |
DataType |
SumAggFunction.ByteSumAggFunction.getResultType() |
DataType |
SumAggFunction.ShortSumAggFunction.getResultType() |
DataType |
SumAggFunction.LongSumAggFunction.getResultType() |
DataType |
SumAggFunction.FloatSumAggFunction.getResultType() |
DataType |
SumAggFunction.DoubleSumAggFunction.getResultType() |
DataType |
SumAggFunction.DecimalSumAggFunction.getResultType() |
DataType |
Count1AggFunction.getResultType() |
DataType |
LeadLagAggFunction.IntLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.ByteLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.ShortLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.LongLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.FloatLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.DoubleLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.BooleanLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.DecimalLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.StringLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.DateLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.TimeLeadLagAggFunction.getResultType() |
DataType |
LeadLagAggFunction.TimestampLeadLagAggFunction.getResultType() |
DataType |
RankLikeAggFunctionBase.getResultType() |
DataType |
AvgAggFunction.ByteAvgAggFunction.getResultType() |
DataType |
AvgAggFunction.ShortAvgAggFunction.getResultType() |
DataType |
AvgAggFunction.IntAvgAggFunction.getResultType() |
DataType |
AvgAggFunction.LongAvgAggFunction.getResultType() |
DataType |
AvgAggFunction.FloatAvgAggFunction.getResultType() |
DataType |
AvgAggFunction.DoubleAvgAggFunction.getResultType() |
DataType |
AvgAggFunction.DecimalAvgAggFunction.getResultType() |
DataType |
CountAggFunction.getResultType() |
DataType |
MinAggFunction.IntMinAggFunction.getResultType() |
DataType |
MinAggFunction.ByteMinAggFunction.getResultType() |
DataType |
MinAggFunction.ShortMinAggFunction.getResultType() |
DataType |
MinAggFunction.LongMinAggFunction.getResultType() |
DataType |
MinAggFunction.FloatMinAggFunction.getResultType() |
DataType |
MinAggFunction.DoubleMinAggFunction.getResultType() |
DataType |
MinAggFunction.DecimalMinAggFunction.getResultType() |
DataType |
MinAggFunction.BooleanMinAggFunction.getResultType() |
DataType |
MinAggFunction.StringMinAggFunction.getResultType() |
DataType |
MinAggFunction.DateMinAggFunction.getResultType() |
DataType |
MinAggFunction.TimeMinAggFunction.getResultType() |
DataType |
MinAggFunction.TimestampMinAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.IntSumWithRetractAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.ByteSumWithRetractAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.ShortSumWithRetractAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.LongSumWithRetractAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.FloatSumWithRetractAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.DoubleSumWithRetractAggFunction.getResultType() |
DataType |
SumWithRetractAggFunction.DecimalSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.IntIncrSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.ByteIncrSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.ShortIncrSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.LongIncrSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.FloatIncrSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.DoubleIncrSumWithRetractAggFunction.getResultType() |
DataType |
IncrSumWithRetractAggFunction.DecimalIncrSumWithRetractAggFunction.getResultType() |
DataType |
ListAggFunction.getResultType() |
DataType |
MaxAggFunction.IntMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.ByteMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.ShortMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.LongMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.FloatMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.DoubleMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.DecimalMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.BooleanMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.StringMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.DateMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.TimeMaxAggFunction.getResultType() |
DataType |
MaxAggFunction.TimestampMaxAggFunction.getResultType() |
abstract DataType |
DeclarativeAggregateFunction.getResultType()
The result type of the function.
|
abstract DataType |
AvgAggFunction.getSumType() |
DataType |
AvgAggFunction.ByteAvgAggFunction.getSumType() |
DataType |
AvgAggFunction.ShortAvgAggFunction.getSumType() |
DataType |
AvgAggFunction.IntAvgAggFunction.getSumType() |
DataType |
AvgAggFunction.LongAvgAggFunction.getSumType() |
DataType |
AvgAggFunction.FloatAvgAggFunction.getSumType() |
DataType |
AvgAggFunction.DoubleAvgAggFunction.getSumType() |
DataType |
AvgAggFunction.DecimalAvgAggFunction.getSumType() |
Constructor and Description |
---|
HiveTableSqlFunction(FunctionIdentifier identifier,
TableFunction hiveUdtf,
DataType implicitResultType,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
org.apache.flink.table.planner.plan.schema.FlinkTableFunction functionImpl,
HiveTableSqlFunction.HiveOperandTypeChecker operandTypeChecker)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static DataType |
ClassDataTypeConverter.fromClassToDataType(Class<?> clazz) |
static DataType |
LogicalTypeDataTypeConverter.fromLogicalTypeToDataType(LogicalType logicalType)
Deprecated.
|
DataType |
DataTypePrecisionFixer.visit(AtomicDataType dataType) |
DataType |
DataTypePrecisionFixer.visit(CollectionDataType collectionDataType) |
DataType |
DataTypePrecisionFixer.visit(FieldsDataType fieldsDataType) |
DataType |
DataTypePrecisionFixer.visit(KeyValueDataType keyValueDataType) |
Modifier and Type | Method and Description |
---|---|
static LogicalType |
LogicalTypeDataTypeConverter.fromDataTypeToLogicalType(DataType dataType)
Deprecated.
It convert
LegacyTypeInformationType to planner types. |
static TypeInformation<?> |
TypeInfoDataTypeConverter.fromDataTypeToTypeInfo(DataType dataType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
DataType |
CsvTableSink.getConsumedDataType() |
default DataType |
TableSink.getConsumedDataType()
Returns the data type consumed by this
TableSink . |
Constructor and Description |
---|
CsvTableSink(String path,
String fieldDelim,
int numFiles,
FileSystem.WriteMode writeMode,
String[] fieldNames,
DataType[] fieldTypes)
A simple
TableSink to emit data as CSV files. |
Modifier and Type | Method and Description |
---|---|
DataType |
CsvTableSource.getProducedDataType() |
default DataType |
TableSource.getProducedDataType()
Returns the
DataType for the produced data of the TableSource . |
Modifier and Type | Method and Description |
---|---|
CsvTableSource.Builder |
CsvTableSource.Builder.field(String fieldName,
DataType fieldType)
Adds a field with the field name and the data type.
|
Modifier and Type | Method and Description |
---|---|
static ResolvedFieldReference[] |
TimestampExtractorUtils.getAccessedFields(TimestampExtractor timestampExtractor,
DataType physicalInputType,
java.util.function.Function<String,String> nameRemapping)
Retrieves all field accesses needed for the given
TimestampExtractor . |
Modifier and Type | Method and Description |
---|---|
DataType |
Column.getDataType() |
Modifier and Type | Method and Description |
---|---|
List<DataType> |
TpcdsSchema.getFieldTypes() |
Constructor and Description |
---|
Column(String name,
DataType dataType) |
Modifier and Type | Class and Description |
---|---|
class |
AtomicDataType
A data type that does not contain further data types (e.g.
|
class |
CollectionDataType
A data type that contains an element type (e.g.
|
class |
FieldsDataType
A data type that contains field data types (e.g.
|
class |
KeyValueDataType
A data type that contains a key and value data type (e.g.
|
Modifier and Type | Method and Description |
---|---|
DataType |
CollectionDataType.bridgedTo(Class<?> newConversionClass) |
abstract DataType |
DataType.bridgedTo(Class<?> newConversionClass)
Adds a hint that data should be represented using the given class when entering or leaving
the table ecosystem.
|
DataType |
AtomicDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
FieldsDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
KeyValueDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
CollectionDataType.getElementDataType() |
DataType |
KeyValueDataType.getKeyDataType() |
DataType |
KeyValueDataType.getValueDataType() |
DataType |
CollectionDataType.notNull() |
abstract DataType |
DataType.notNull()
Adds a hint that null values are not expected in the data for this type.
|
DataType |
AtomicDataType.notNull() |
DataType |
FieldsDataType.notNull() |
DataType |
KeyValueDataType.notNull() |
DataType |
CollectionDataType.nullable() |
abstract DataType |
DataType.nullable()
Adds a hint that null values are expected in the data for this type (default behavior).
|
DataType |
AtomicDataType.nullable() |
DataType |
FieldsDataType.nullable() |
DataType |
KeyValueDataType.nullable() |
Modifier and Type | Method and Description |
---|---|
Map<String,DataType> |
FieldsDataType.getFieldDataTypes() |
Constructor and Description |
---|
CollectionDataType(LogicalType logicalType,
Class<?> conversionClass,
DataType elementDataType) |
CollectionDataType(LogicalType logicalType,
DataType elementDataType) |
KeyValueDataType(LogicalType logicalType,
Class<?> conversionClass,
DataType keyDataType,
DataType valueDataType) |
KeyValueDataType(LogicalType logicalType,
DataType keyDataType,
DataType valueDataType) |
Constructor and Description |
---|
FieldsDataType(LogicalType logicalType,
Class<?> conversionClass,
Map<String,DataType> fieldDataTypes) |
FieldsDataType(LogicalType logicalType,
Map<String,DataType> fieldDataTypes) |
Modifier and Type | Method and Description |
---|---|
static DataType |
DataTypeExtractor.extractFromGeneric(DataTypeLookup lookup,
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(DataTypeLookup lookup,
Class<?> baseClass,
Method method)
Extracts a data type from a method return type by considering surrounding classes and method
annotation.
|
static DataType |
DataTypeExtractor.extractFromMethodParameter(DataTypeLookup lookup,
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(DataTypeLookup lookup,
DataTypeTemplate template,
Type type)
Extracts a data type from a type without considering surrounding classes but templates.
|
static DataType |
DataTypeExtractor.extractFromType(DataTypeLookup lookup,
Type type)
Extracts a data type from a type without considering surrounding classes or templates.
|
Modifier and Type | Field and Description |
---|---|
DataType |
DataTypeTemplate.dataType |
Modifier and Type | Method and Description |
---|---|
static DataType |
ExtractionUtils.createRawType(DataTypeLookup lookup,
Class<? extends TypeSerializer<?>> rawSerializer,
Class<?> conversionClass)
Creates a raw data type.
|
Modifier and Type | Method and Description |
---|---|
static DataTypeTemplate |
DataTypeTemplate.fromAnnotation(DataTypeHint hint,
DataType dataType)
Creates an instance from the given
DataTypeHint with a resolved data type if available. |
Modifier and Type | Method and Description |
---|---|
DataType |
TypeInferenceUtil.Result.getOutputDataType() |
DataType |
TypeTransformation.transform(DataType typeToTransform)
Transforms the given data type to a different data type.
|
Modifier and Type | Method and Description |
---|---|
Optional<DataType> |
TypeInferenceUtil.Result.getAccumulatorDataType() |
List<DataType> |
CallContext.getArgumentDataTypes()
Returns a resolved list of the call's argument types.
|
List<DataType> |
TypeInferenceUtil.Result.getExpectedArgumentTypes() |
Optional<DataType> |
CallContext.getOutputDataType()
Returns the inferred output data type of the function call.
|
Optional<List<DataType>> |
TypeInference.getTypedArguments() |
Optional<DataType> |
ArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure)
Main logic for inferring and validating an argument.
|
Optional<List<DataType>> |
InputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure)
Main logic for inferring and validating the input arguments.
|
Optional<DataType> |
TypeStrategy.inferType(CallContext callContext)
Infers a type from the given function call.
|
Modifier and Type | Method and Description |
---|---|
static ExplicitArgumentTypeStrategy |
InputTypeStrategies.explicit(DataType expectedDataType)
Strategy for an argument that corresponds to an explicitly defined type casting.
|
static TypeStrategy |
TypeStrategies.explicit(DataType dataType)
Type strategy that returns a fixed
DataType . |
static InputTypeStrategy |
InputTypeStrategies.explicitSequence(DataType... expectedDataTypes)
Strategy for a function signature of explicitly defined types like
f(STRING, INT) . |
static InputTypeStrategy |
InputTypeStrategies.explicitSequence(String[] argumentNames,
DataType[] expectedDataTypes)
Strategy for a named function signature of explicitly defined types like
f(s STRING, i INT) . |
DataType |
TypeTransformation.transform(DataType typeToTransform)
Transforms the given data type to a different data type.
|
Modifier and Type | Method and Description |
---|---|
TypeInference.Builder |
TypeInference.Builder.typedArguments(List<DataType> argumentTypes)
Sets the list of argument types for specifying a fixed, not overloaded, not vararg input
signature explicitly.
|
Constructor and Description |
---|
Result(List<DataType> expectedArgumentTypes,
DataType accumulatorDataType,
DataType outputDataType) |
Constructor and Description |
---|
Result(List<DataType> expectedArgumentTypes,
DataType accumulatorDataType,
DataType outputDataType) |
Modifier and Type | Method and Description |
---|---|
Optional<DataType> |
OutputArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
OrArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
ExplicitArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
LiteralArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
AndArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
AnyArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<List<DataType>> |
SequenceInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
WildcardInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
OrInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
VaryingSequenceInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<DataType> |
MappingTypeStrategy.inferType(CallContext callContext) |
Optional<DataType> |
ExplicitTypeStrategy.inferType(CallContext callContext) |
Optional<DataType> |
MissingTypeStrategy.inferType(CallContext callContext) |
Constructor and Description |
---|
ExplicitArgumentTypeStrategy(DataType expectedDataType) |
ExplicitTypeStrategy(DataType explicitDataType) |
Modifier and Type | Method and Description |
---|---|
DataType |
LegacyRawTypeTransformation.transform(DataType typeToTransform) |
DataType |
DataTypeConversionClassTransformation.transform(DataType dataType) |
DataType |
LegacyDecimalTypeTransformation.transform(DataType typeToTransform) |
Modifier and Type | Method and Description |
---|---|
DataType |
LegacyRawTypeTransformation.transform(DataType typeToTransform) |
DataType |
DataTypeConversionClassTransformation.transform(DataType dataType) |
DataType |
LegacyDecimalTypeTransformation.transform(DataType typeToTransform) |
Modifier and Type | Method and Description |
---|---|
List<DataType> |
AdaptedCallContext.getArgumentDataTypes() |
List<DataType> |
UnknownCallContext.getArgumentDataTypes() |
Optional<DataType> |
AdaptedCallContext.getOutputDataType() |
Optional<DataType> |
UnknownCallContext.getOutputDataType() |
Modifier and Type | Method and Description |
---|---|
void |
AdaptedCallContext.setExpectedArguments(List<DataType> expectedArguments) |
Constructor and Description |
---|
AdaptedCallContext(CallContext originalContext,
DataType outputDataType) |
Modifier and Type | Method and Description |
---|---|
static DataType |
TypeConversions.fromLegacyInfoToDataType(TypeInformation<?> typeInfo) |
static DataType[] |
TypeConversions.fromLegacyInfoToDataType(TypeInformation<?>[] typeInfo) |
static DataType |
TypeConversions.fromLogicalToDataType(LogicalType logicalType) |
static DataType[] |
TypeConversions.fromLogicalToDataType(LogicalType[] logicalTypes) |
static DataType |
DataTypeUtils.replaceLogicalType(DataType dataType,
LogicalType replacement)
Replaces the
LogicalType of a DataType , i.e., it keeps the bridging class. |
static DataType |
LogicalTypeDataTypeConverter.toDataType(LogicalType logicalType)
Returns the data type of a logical type without explicit conversions.
|
static DataType |
LegacyTypeInfoDataTypeConverter.toDataType(TypeInformation<?> typeInfo) |
static DataType |
DataTypeUtils.transform(DataType typeToTransform,
TypeTransformation... transformations)
Transforms the given data type (can be nested) to a different data type using the given
transformations.
|
Modifier and Type | Method and Description |
---|---|
static Optional<DataType> |
ClassDataTypeConverter.extractDataType(Class<?> clazz)
Returns the clearly identifiable data type if possible.
|
static Optional<DataType> |
ValueDataTypeConverter.extractDataType(Object value)
Returns the clearly identifiable data type if possible.
|
static Optional<DataType> |
TypeConversions.fromClassToDataType(Class<?> clazz) |
Modifier and Type | Method and Description |
---|---|
protected abstract R |
DataTypeDefaultVisitor.defaultMethod(DataType dataType) |
static TableSchema |
DataTypeUtils.expandCompositeTypeToSchema(DataType dataType)
Expands a composite
DataType to a corresponding TableSchema . |
static LogicalType |
TypeConversions.fromDataToLogicalType(DataType dataType) |
static LogicalType[] |
TypeConversions.fromDataToLogicalType(DataType[] dataTypes) |
static TypeInformation<?> |
TypeConversions.fromDataTypeToLegacyInfo(DataType dataType) |
static TypeInformation<?>[] |
TypeConversions.fromDataTypeToLegacyInfo(DataType[] dataType) |
static DataType |
DataTypeUtils.replaceLogicalType(DataType dataType,
LogicalType replacement)
Replaces the
LogicalType of a DataType , i.e., it keeps the bridging class. |
static TypeInformation<?> |
LegacyTypeInfoDataTypeConverter.toLegacyTypeInfo(DataType dataType) |
static LogicalType |
LogicalTypeDataTypeConverter.toLogicalType(DataType dataType)
Returns the logical type of a data type.
|
static DataType |
DataTypeUtils.transform(DataType typeToTransform,
TypeTransformation... transformations)
Transforms the given data type (can be nested) to a different data type using the given
transformations.
|
Modifier and Type | Method and Description |
---|---|
DataType[] |
FieldInfoUtils.TypeInfoSchema.getFieldTypes() |
Modifier and Type | Method and Description |
---|---|
static int[] |
TypeMappingUtils.computePhysicalIndices(List<TableColumn> logicalColumns,
DataType physicalType,
java.util.function.Function<String,String> nameRemapping)
Computes indices of physical fields corresponding to the selected logical fields of a
TableSchema . |
Modifier and Type | Method and Description |
---|---|
DataType |
SpendReportTableSink.getConsumedDataType() |
DataType |
UnboundedTransactionTableSource.getProducedDataType() |
DataType |
BoundedTransactionTableSource.getProducedDataType() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.