Modifier and Type | Method and Description |
---|---|
DataType[] |
HBaseTableSchema.getQualifierDataTypes(String family) |
Modifier and Type | Method and Description |
---|---|
Optional<DataType> |
HBaseTableSchema.getRowKeyDataType() |
Modifier and Type | Method and Description |
---|---|
void |
HBaseTableSchema.addColumn(String family,
String qualifier,
DataType type) |
void |
HBaseTableSchema.setRowKey(String rowKeyName,
DataType type) |
Modifier and Type | Method and Description |
---|---|
DataType |
JdbcTableSource.getProducedDataType() |
Modifier and Type | Method and Description |
---|---|
JdbcDynamicOutputFormatBuilder |
JdbcDynamicOutputFormatBuilder.setFieldDataTypes(DataType[] fieldDataTypes) |
Constructor and Description |
---|
JdbcRowDataLookupFunction(JdbcOptions options,
JdbcLookupOptions lookupOptions,
String[] fieldNames,
DataType[] fieldTypes,
String[] keyNames,
RowType rowType) |
Modifier and Type | Method and Description |
---|---|
DataType |
HiveTableSink.getConsumedDataType() |
DataType |
HiveTableSource.getProducedDataType() |
Modifier and Type | Method and Description |
---|---|
static HiveTablePartition |
HiveTableSource.toHiveTablePartition(List<String> partitionKeys,
String[] fieldNames,
DataType[] fieldTypes,
HiveShim shim,
Properties tableProps,
String defaultPartitionName,
org.apache.hadoop.hive.metastore.api.Partition partition) |
Constructor and Description |
---|
HiveRowDataPartitionComputer(HiveShim hiveShim,
String defaultPartValue,
String[] columnNames,
DataType[] columnTypes,
String[] partitionColumns) |
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) |
HiveVectorizedParquetSplitReader(String hiveVersion,
org.apache.hadoop.mapred.JobConf jobConf,
String[] fieldNames,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split) |
Constructor and Description |
---|
CsvInputFormat(Path[] filePaths,
DataType[] fieldTypes,
String[] fieldNames,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema,
RowType formatRowType,
int[] selectFields,
List<String> partitionKeys,
String defaultPartValue,
long limit,
int[] csvSelectFieldToProjectFieldMapping,
int[] csvSelectFieldToCsvFieldMapping,
boolean ignoreParseErrors) |
Constructor and Description |
---|
JsonInputFormat(Path[] filePaths,
DataType[] fieldTypes,
String[] fieldNames,
int[] selectFields,
List<String> partitionKeys,
String defaultPartValue,
long limit,
int[] jsonSelectFieldToProjectFieldMapping,
int[] jsonSelectFieldToJsonFieldMapping,
JsonRowDataDeserializationSchema deserializationSchema) |
Constructor and Description |
---|
ParquetInputFormat(Path[] paths,
String[] fullFieldNames,
DataType[] fullFieldTypes,
int[] selectedFields,
String partDefaultName,
long limit,
Configuration conf,
boolean utcTimestamp) |
Modifier and Type | Method and Description |
---|---|
static ParquetColumnarRowSplitReader |
ParquetSplitReaderUtil.genPartColumnarRowReader(boolean utcTimestamp,
boolean caseSensitive,
Configuration conf,
String[] fullFieldNames,
DataType[] fullFieldTypes,
Map<String,Object> partitionSpec,
int[] selectedFields,
int batchSize,
Path path,
long splitStart,
long splitLength)
Util for generating partitioned
ParquetColumnarRowSplitReader . |
Modifier and Type | Method and Description |
---|---|
static org.apache.orc.TypeDescription |
OrcSplitReaderUtil.convertToOrcTypeWithPart(String[] fullFieldNames,
DataType[] fullFieldTypes,
Collection<String> partitionKeys) |
static OrcColumnarRowSplitReader<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> |
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 . |
Constructor and Description |
---|
OrcRowDataInputFormat(Path[] paths,
String[] fullFieldNames,
DataType[] fullFieldTypes,
int[] selectedFields,
String partDefaultName,
long limit,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
static OrcColumnarRowSplitReader<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch> |
OrcNoHiveSplitReaderUtil.genPartColumnarRowReader(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 | Field and Description |
---|---|
protected DataType |
KafkaDynamicSinkBase.consumedDataType
Consumed data type of the table.
|
protected DataType |
KafkaDynamicSourceBase.outputDataType |
Modifier and Type | Method and Description |
---|---|
protected KafkaDynamicSinkBase |
KafkaDynamicTableFactory.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
protected KafkaDynamicSinkBase |
Kafka011DynamicTableFactory.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
protected KafkaDynamicSinkBase |
Kafka010DynamicTableFactory.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
protected abstract KafkaDynamicSinkBase |
KafkaDynamicTableFactoryBase.createKafkaTableSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat)
Constructs the version-specific Kafka table sink.
|
protected KafkaDynamicSourceBase |
KafkaDynamicTableFactory.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis) |
protected KafkaDynamicSourceBase |
Kafka011DynamicTableFactory.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis) |
protected KafkaDynamicSourceBase |
Kafka010DynamicTableFactory.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis) |
protected abstract KafkaDynamicSourceBase |
KafkaDynamicTableFactoryBase.createKafkaTableSource(DataType producedDataType,
String topic,
Properties properties,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
StartupMode startupMode,
Map<KafkaTopicPartition,Long> specificStartupOffsets,
long startupTimestampMillis)
Constructs the version-specific Kafka table source.
|
Modifier and Type | Method and Description |
---|---|
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()
Data type of a row type with no fields.
|
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.toPhysicalRowDataType()
Converts all physical columns of this schema into a (possibly nested) row data type.
|
DataType |
TableSchema.toRowDataType()
Converts all columns of this schema into a (possibly nested) row data type.
|
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 ApiExpression |
Expressions.lit(Object v,
DataType dataType)
Creates a SQL literal of a given
DataType . |
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 ApiExpression |
Expressions.nullOf(DataType dataType)
Returns a null literal value of a given data type.
|
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 |
---|---|
OutType |
BaseExpressions.cast(DataType toType)
Converts a value to a given data type.
|
Modifier and Type | Method and Description |
---|---|
DataType |
DataTypeFactory.createDataType(AbstractDataType<?> abstractDataType)
Creates a type out of an
AbstractDataType . |
<T> DataType |
DataTypeFactory.createDataType(Class<T> clazz)
Creates a type by analyzing the given class.
|
DataType |
DataTypeFactory.createDataType(String name)
Creates a type by a fully or partially defined name.
|
DataType |
DataTypeFactory.createDataType(UnresolvedIdentifier identifier)
Creates a type by a fully or partially defined identifier.
|
<T> DataType |
DataTypeFactory.createRawDataType(Class<T> clazz)
Creates a RAW type for the given class in cases where no serializer is known and a generic
serializer should be used.
|
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 |
---|---|
I |
DecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context,
DataType producedDataType)
Creates runtime decoder implementation that is configured to produce data of the given data
type.
|
I |
EncodingFormat.createRuntimeEncoder(DynamicTableSink.Context context,
DataType consumedDataType)
Creates runtime encoder implementation that is configured to consume data of the given data
type.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.DataStructureConverter |
DynamicTableSink.Context.createDataStructureConverter(DataType consumedDataType)
Creates a converter for mapping between Flink's internal data structures and objects
specified by the given
DataType that can be passed into a runtime implementation. |
TypeInformation<?> |
DynamicTableSink.Context.createTypeInformation(DataType consumedDataType)
Creates type information describing the internal data structures of the given
DataType . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource.DataStructureConverter |
DynamicTableSource.Context.createDataStructureConverter(DataType producedDataType)
Creates a converter for mapping between objects specified by the given
DataType
and Flink's internal data structures that can be passed into a runtime implementation. |
TypeInformation<?> |
DynamicTableSource.Context.createTypeInformation(DataType producedDataType)
Creates type information describing the internal data structures of the given
DataType . |
Modifier and Type | Method and Description |
---|---|
void |
SupportsComputedColumnPushDown.applyComputedColumn(SupportsComputedColumnPushDown.ComputedColumnConverter converter,
DataType outputDataType)
|
Modifier and Type | Method and Description |
---|---|
static RawByteArrayConverter<?> |
RawByteArrayConverter.create(DataType dataType) |
static StructuredObjectConverter<?> |
StructuredObjectConverter.create(DataType dataType) |
static ArrayObjectArrayConverter<?> |
ArrayObjectArrayConverter.create(DataType dataType) |
static RawObjectConverter<?> |
RawObjectConverter.create(DataType dataType) |
static RowRowConverter |
RowRowConverter.create(DataType dataType) |
static YearMonthIntervalPeriodConverter |
YearMonthIntervalPeriodConverter.create(DataType dataType) |
static <E> ArrayObjectArrayConverter<E> |
ArrayObjectArrayConverter.createForElement(DataType elementDataType) |
static MapMapConverter<?,?> |
MapMapConverter.createForMapType(DataType dataType) |
static MapMapConverter<?,?> |
MapMapConverter.createForMultisetType(DataType dataType) |
static DataStructureConverter<Object,Object> |
DataStructureConverters.getConverter(DataType dataType)
Returns a converter for the given
DataType . |
Modifier and Type | Method and Description |
---|---|
static DataFormatConverters.DataFormatConverter |
DataFormatConverters.getConverterForDataType(DataType originDataType)
|
Constructor and Description |
---|
AbstractRowDataConverter(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.
OldCsv supports derive schema from table schema by default, it is no
longer necessary to explicitly declare the format schema. This method will be removed in
the future. |
Schema |
Schema.field(String fieldName,
DataType fieldType)
Adds a field with the field name and the data type.
|
Modifier and Type | Method and Description |
---|---|
DeserializationSchema<RowData> |
ChangelogCsvFormat.createRuntimeDecoder(DynamicTableSource.Context context,
DataType producedDataType) |
Constructor and Description |
---|
SocketDynamicTableSource(String hostname,
int port,
byte byteDelimiter,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
DataType producedDataType) |
Modifier and Type | Method and Description |
---|---|
DataType |
TableReferenceExpression.getOutputDataType() |
DataType |
LocalReferenceExpression.getOutputDataType() |
DataType |
FieldReferenceExpression.getOutputDataType() |
DataType |
ValueLiteralExpression.getOutputDataType() |
DataType |
ResolvedExpression.getOutputDataType()
Returns the data type of the computation result.
|
DataType |
CallExpression.getOutputDataType() |
DataType |
TypeLiteralExpression.getOutputDataType() |
Modifier and Type | Method and Description |
---|---|
static LocalReferenceExpression |
ApiExpressionUtils.localRef(String name,
DataType dataType) |
CallExpression |
UnresolvedCallExpression.resolve(List<ResolvedExpression> args,
DataType dataType) |
static TypeLiteralExpression |
ApiExpressionUtils.typeLiteral(DataType dataType) |
static ValueLiteralExpression |
ApiExpressionUtils.valueLiteral(Object value,
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) |
TypeLiteralExpression(DataType dataType) |
ValueLiteralExpression(Object value,
DataType dataType) |
Modifier and Type | Method and Description |
---|---|
CallExpression |
ExpressionResolver.PostResolverFactory.array(DataType dataType,
ResolvedExpression... expression) |
CallExpression |
ExpressionResolver.PostResolverFactory.cast(ResolvedExpression expression,
DataType dataType) |
CallExpression |
ExpressionResolver.PostResolverFactory.get(ResolvedExpression composite,
ValueLiteralExpression key,
DataType dataType) |
CallExpression |
ExpressionResolver.PostResolverFactory.map(DataType dataType,
ResolvedExpression... expression) |
CallExpression |
ExpressionResolver.PostResolverFactory.row(DataType dataType,
ResolvedExpression... expression) |
Modifier and Type | Method and Description |
---|---|
default DataType[] |
FileSystemFormatFactory.ReaderContext.getFormatFieldTypes()
Get field types without partition keys.
|
default DataType[] |
FileSystemFormatFactory.WriterContext.getFormatFieldTypes()
Get field types without partition keys.
|
Modifier and Type | Method and Description |
---|---|
DataType |
FileSystemTableSink.getConsumedDataType() |
DataType |
FileSystemTableSource.getProducedDataType() |
Modifier and Type | Method and Description |
---|---|
static Object |
RowPartitionComputer.restorePartValueFromType(String valStr,
DataType type)
Restore partition value from string and type.
|
Constructor and Description |
---|
FileSystemLookupFunction(InputFormat<RowData,T> inputFormat,
String[] lookupKeys,
String[] producedNames,
DataType[] producedTypes,
java.time.Duration cacheTTL) |
RowDataPartitionComputer(String defaultPartValue,
String[] columnNames,
DataType[] columnTypes,
String[] partitionColumns) |
Modifier and Type | Method and Description |
---|---|
BuiltInFunctionDefinition.Builder |
BuiltInFunctionDefinition.Builder.typedArguments(DataType... argumentTypes) |
Modifier and Type | Field and Description |
---|---|
protected DataType[] |
HiveScalarFunction.argTypes |
Modifier and Type | Method and Description |
---|---|
DataType |
HiveGenericUDTF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveFunction.getHiveResultType(Object[] constantArguments,
DataType[] argTypes)
Get result type by arguments and argTypes.
|
DataType |
HiveGenericUDAF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveSimpleUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveGenericUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
Modifier and Type | Method and Description |
---|---|
DataType |
HiveGenericUDTF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveFunction.getHiveResultType(Object[] constantArguments,
DataType[] argTypes)
Get result type by arguments and argTypes.
|
DataType |
HiveGenericUDAF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveSimpleUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
DataType |
HiveGenericUDF.getHiveResultType(Object[] constantArguments,
DataType[] argTypes) |
void |
HiveGenericUDTF.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes) |
void |
HiveFunction.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes)
Set arguments and argTypes for Function instance.
|
void |
HiveGenericUDAF.setArgumentTypesAndConstants(Object[] constantArguments,
DataType[] argTypes) |
void |
HiveScalarFunction.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 |
---|---|
QueryOperation |
OperationTreeBuilder.values(DataType rowType,
Expression... expressions) |
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[] |
MaxAggFunction.getAggBufferTypes() |
DataType[] |
RankAggFunction.getAggBufferTypes() |
DataType[] |
AvgAggFunction.getAggBufferTypes() |
DataType[] |
MinAggFunction.getAggBufferTypes() |
DataType[] |
IncrSumAggFunction.getAggBufferTypes() |
DataType[] |
Count1AggFunction.getAggBufferTypes() |
DataType[] |
SingleValueAggFunction.getAggBufferTypes() |
abstract DataType[] |
DeclarativeAggregateFunction.getAggBufferTypes()
All types of the aggregate buffer.
|
DataType[] |
Sum0AggFunction.getAggBufferTypes() |
DataType[] |
SumAggFunction.getAggBufferTypes() |
DataType[] |
CountAggFunction.getAggBufferTypes() |
DataType[] |
ListAggFunction.getAggBufferTypes() |
DataType[] |
IncrSumWithRetractAggFunction.getAggBufferTypes() |
DataType[] |
DenseRankAggFunction.getAggBufferTypes() |
DataType[] |
SumWithRetractAggFunction.getAggBufferTypes() |
DataType[] |
LeadLagAggFunction.getAggBufferTypes() |
DataType[] |
RowNumberAggFunction.getAggBufferTypes() |
DataType |
RankLikeAggFunctionBase.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() |
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 |
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 |
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 |
Count1AggFunction.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() |
abstract DataType |
DeclarativeAggregateFunction.getResultType()
The result type of the function.
|
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 |
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 |
CountAggFunction.getResultType() |
DataType |
ListAggFunction.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 |
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 |
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 |
RowNumberAggFunction.getResultType() |
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() |
Modifier and Type | Method and Description |
---|---|
List<DataType> |
OperatorBindingCallContext.getArgumentDataTypes() |
List<DataType> |
CallBindingCallContext.getArgumentDataTypes() |
Optional<DataType> |
OperatorBindingCallContext.getOutputDataType() |
Optional<DataType> |
CallBindingCallContext.getOutputDataType() |
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 |
---|---|
DataType |
SelectTableSinkBase.getConsumedDataType() |
Modifier and Type | Method and Description |
---|---|
static AbstractArrowTableSource |
ArrowUtils.createArrowTableSource(DataType dataType,
String fileName) |
Modifier and Type | Method and Description |
---|---|
DataType |
AbstractArrowTableSource.getProducedDataType() |
Constructor and Description |
---|
ArrowTableSource(DataType dataType,
byte[][] arrowData) |
RowArrowTableSource(DataType dataType,
byte[][] arrowData) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.DataStructureConverter |
SinkRuntimeProviderContext.createDataStructureConverter(DataType consumedDataType) |
TypeInformation<?> |
SinkRuntimeProviderContext.createTypeInformation(DataType consumedDataType) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource.DataStructureConverter |
LookupRuntimeProviderContext.createDataStructureConverter(DataType producedDataType) |
DynamicTableSource.DataStructureConverter |
ScanRuntimeProviderContext.createDataStructureConverter(DataType producedDataType) |
TypeInformation<?> |
LookupRuntimeProviderContext.createTypeInformation(DataType producedDataType) |
TypeInformation<?> |
ScanRuntimeProviderContext.createTypeInformation(DataType producedDataType) |
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 |
BatchSelectTableSink.getConsumedDataType() |
DataType |
StreamSelectTableSink.getConsumedDataType() |
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 (i.e.
|
class |
KeyValueDataType
A data type that contains a key and value data type (e.g.
|
Modifier and Type | Method and Description |
---|---|
DataType |
FieldsDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
AtomicDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
CollectionDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
KeyValueDataType.bridgedTo(Class<?> newConversionClass) |
DataType |
CollectionDataType.getElementDataType() |
DataType |
KeyValueDataType.getKeyDataType() |
DataType |
KeyValueDataType.getValueDataType() |
DataType |
FieldsDataType.notNull() |
DataType |
AtomicDataType.notNull() |
DataType |
CollectionDataType.notNull() |
DataType |
KeyValueDataType.notNull() |
DataType |
FieldsDataType.nullable() |
DataType |
AtomicDataType.nullable() |
DataType |
CollectionDataType.nullable() |
DataType |
KeyValueDataType.nullable() |
DataType |
UnresolvedDataType.toDataType(DataTypeFactory factory)
Converts this instance to a resolved
DataType possibly enriched with additional
nullability and conversion class information. |
Modifier and Type | Method and Description |
---|---|
abstract List<DataType> |
DataType.getChildren() |
List<DataType> |
FieldsDataType.getChildren() |
List<DataType> |
AtomicDataType.getChildren() |
List<DataType> |
CollectionDataType.getChildren() |
List<DataType> |
KeyValueDataType.getChildren() |
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,
List<DataType> fieldDataTypes) |
FieldsDataType(LogicalType logicalType,
List<DataType> fieldDataTypes) |
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.
|
Modifier and Type | Method and Description |
---|---|
DataType |
TypeInferenceUtil.Result.getOutputDataType() |
static DataType |
TypeInferenceUtil.inferOutputType(CallContext callContext,
TypeStrategy outputTypeStrategy)
Infers an output type using the given
TypeStrategy . |
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 CallContext |
TypeInferenceUtil.adaptArguments(TypeInference typeInference,
CallContext callContext,
DataType outputType)
Adapts the call's argument if necessary.
|
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.
|
TypeInference.Builder |
TypeInference.Builder.typedArguments(DataType... argumentTypes) |
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> |
AnyArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
OrArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
OutputArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
ExplicitArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
FamilyArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
LiteralArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
RootArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<DataType> |
AndArgumentTypeStrategy.inferArgumentType(CallContext callContext,
int argumentPos,
boolean throwOnFailure) |
Optional<List<DataType>> |
VaryingSequenceInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
SequenceInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
OrInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
MapInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
ArrayInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<List<DataType>> |
WildcardInputTypeStrategy.inferInputTypes(CallContext callContext,
boolean throwOnFailure) |
Optional<DataType> |
UseArgumentTypeStrategy.inferType(CallContext callContext) |
Optional<DataType> |
MappingTypeStrategy.inferType(CallContext callContext) |
Optional<DataType> |
MissingTypeStrategy.inferType(CallContext callContext) |
Optional<DataType> |
ExplicitTypeStrategy.inferType(CallContext callContext) |
Constructor and Description |
---|
ExplicitArgumentTypeStrategy(DataType expectedDataType) |
ExplicitTypeStrategy(DataType explicitDataType) |
Modifier and Type | Method and Description |
---|---|
DataType |
DataTypeConversionClassTransformation.transform(DataType dataType) |
DataType |
LegacyDecimalTypeTransformation.transform(DataType typeToTransform) |
DataType |
LegacyRawTypeTransformation.transform(DataType typeToTransform) |
Modifier and Type | Method and Description |
---|---|
DataType |
DataTypeConversionClassTransformation.transform(DataType dataType) |
DataType |
LegacyDecimalTypeTransformation.transform(DataType typeToTransform) |
DataType |
LegacyRawTypeTransformation.transform(DataType typeToTransform) |
Modifier and Type | Method and Description |
---|---|
List<DataType> |
UnknownCallContext.getArgumentDataTypes() |
List<DataType> |
AdaptedCallContext.getArgumentDataTypes() |
Optional<DataType> |
UnknownCallContext.getOutputDataType() |
Optional<DataType> |
AdaptedCallContext.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 boolean |
DataTypeUtils.isInternal(DataType dataType)
Checks whether a given data type is an internal data structure.
|
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 . |
static Object |
PartitionPathUtils.convertStringToInternalValue(String valStr,
DataType type)
Restore partition value from string and type.
|
static GenericRowData |
PartitionPathUtils.fillPartitionValueForRecord(String[] fieldNames,
DataType[] fieldTypes,
int[] selectFields,
List<String> partitionKeys,
Path path,
String defaultPartValue)
Extract partition value from path and fill to record.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.