Modifier and Type | Method and Description |
---|---|
static boolean |
HBaseTypeUtils.isSupportedType(LogicalType type)
Checks whether the given
LogicalType is supported in HBase connector. |
Modifier and Type | Field and Description |
---|---|
protected LogicalType[] |
AbstractJdbcRowConverter.fieldTypes |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter |
AbstractJdbcRowConverter.createExternalConverter(LogicalType type) |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.createInternalConverter(LogicalType type) |
org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter |
PostgresRowConverter.createInternalConverter(LogicalType type) |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter |
AbstractJdbcRowConverter.createNullableExternalConverter(LogicalType type)
Create a nullable JDBC f
JdbcSerializationConverter from given sql type. |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter |
PostgresRowConverter.createNullableExternalConverter(LogicalType type) |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.createNullableInternalConverter(LogicalType type)
Create a nullable runtime
JdbcDeserializationConverter from given LogicalType . |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter |
AbstractJdbcRowConverter.wrapIntoNullableExternalConverter(org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter jdbcSerializationConverter,
LogicalType type) |
Modifier and Type | Method and Description |
---|---|
static LogicalType |
AvroSchemaConverter.extractValueTypeToAvroMap(LogicalType type) |
Modifier and Type | Method and Description |
---|---|
static org.apache.avro.Schema |
AvroSchemaConverter.convertToSchema(LogicalType logicalType)
Converts Flink SQL
LogicalType (can be nested) into an Avro schema. |
static org.apache.avro.Schema |
AvroSchemaConverter.convertToSchema(LogicalType logicalType,
String rowName) |
static LogicalType |
AvroSchemaConverter.extractValueTypeToAvroMap(LogicalType type) |
Modifier and Type | Method and Description |
---|---|
static ColumnReader |
ParquetSplitReaderUtil.createColumnReader(boolean utcTimestamp,
LogicalType fieldType,
org.apache.parquet.column.ColumnDescriptor descriptor,
org.apache.parquet.column.page.PageReader pageReader) |
static WritableColumnVector |
ParquetSplitReaderUtil.createWritableColumnVector(int batchSize,
LogicalType fieldType,
org.apache.parquet.schema.PrimitiveType primitiveType) |
Constructor and Description |
---|
ParquetColumnarRowSplitReader(boolean utcTimestamp,
boolean caseSensitive,
Configuration conf,
LogicalType[] selectedTypes,
String[] selectedFieldNames,
ParquetColumnarRowSplitReader.ColumnBatchGenerator generator,
int batchSize,
org.apache.hadoop.fs.Path path,
long splitStart,
long splitLength) |
Modifier and Type | Method and Description |
---|---|
static org.apache.orc.TypeDescription |
OrcSplitReaderUtil.logicalTypeToOrcType(LogicalType type)
See
org.apache.flink.table.catalog.hive.util.HiveTypeUtil . |
Constructor and Description |
---|
OrcNoHiveBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes) |
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
AbstractOrcNoHiveVector.createFlinkVectorFromConstant(LogicalType type,
Object value,
int batchSize)
Create flink vector by hive vector from constant.
|
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
AbstractOrcColumnVector.createFlinkVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
LogicalType logicalType) |
static ColumnVector |
AbstractOrcColumnVector.createFlinkVectorFromConstant(LogicalType type,
Object value,
int batchSize)
Create flink vector by hive vector from constant.
|
Constructor and Description |
---|
RowDataVectorizer(String schema,
LogicalType[] fieldTypes) |
Modifier and Type | Method and Description |
---|---|
BulkWriter.Factory<RowData> |
HiveShimV200.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes) |
BulkWriter.Factory<RowData> |
HiveShimV100.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes) |
BulkWriter.Factory<RowData> |
HiveShim.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes)
Create orc
BulkWriter.Factory for different hive versions. |
Modifier and Type | Method and Description |
---|---|
static ArrayData.ElementGetter |
ArrayData.createElementGetter(LogicalType elementType)
Creates an accessor for getting elements in an internal array data structure at the given
position.
|
static RowData.FieldGetter |
RowData.createFieldGetter(LogicalType fieldType,
int fieldPos)
Creates an accessor for getting elements in an internal row data structure at the given
position.
|
static Object |
ArrayData.get(ArrayData array,
int pos,
LogicalType elementType)
Deprecated.
Use
ArrayData.createElementGetter(LogicalType) for avoiding logical types during
runtime. |
static Object |
RowData.get(RowData row,
int pos,
LogicalType fieldType)
Deprecated.
Use
RowData.createFieldGetter(LogicalType, int) for avoiding logical types
during runtime. |
Modifier and Type | Method and Description |
---|---|
static int |
BinaryArrayData.calculateFixLengthPartSize(LogicalType type)
It store real value when type is primitive.
|
static boolean |
BinaryRowData.isInFixedLengthPart(LogicalType type)
If it is a fixed-length field, we can call this BinaryRowData's setXX method for in-place
updates.
|
static boolean |
BinaryRowData.isMutable(LogicalType type) |
Map<?,?> |
BinaryMapData.toJavaMap(LogicalType keyType,
LogicalType valueType) |
<T> T[] |
BinaryArrayData.toObjectArray(LogicalType elementType) |
Modifier and Type | Method and Description |
---|---|
static Map<Object,Object> |
MapDataUtil.convertToJavaMap(MapData map,
LogicalType keyType,
LogicalType valueType)
|
static GenericRowData |
RowDataUtil.toGenericRow(RowData row,
LogicalType[] types) |
Modifier and Type | Method and Description |
---|---|
static BinaryArrayWriter.NullSetter |
BinaryArrayWriter.createNullSetter(LogicalType elementType)
Creates an for accessor setting the elements of an array writer to
null during
runtime. |
static BinaryWriter.ValueSetter |
BinaryWriter.createValueSetter(LogicalType elementType)
Creates an accessor for setting the elements of an array writer during runtime.
|
void |
BinaryArrayWriter.setNullAt(int pos,
LogicalType type)
Deprecated.
Use
BinaryArrayWriter.createNullSetter(LogicalType) for avoiding logical types during
runtime. |
static void |
BinaryWriter.write(BinaryWriter writer,
int pos,
Object o,
LogicalType type,
TypeSerializer<?> serializer)
Deprecated.
Use
BinaryWriter.createValueSetter(LogicalType) for avoiding logical types during
runtime. |
Constructor and Description |
---|
ChangelogCsvDeserializer(List<LogicalType> parsingTypes,
DynamicTableSource.DataStructureConverter converter,
TypeInformation<RowData> producedTypeInfo,
String columnDelimiter) |
Modifier and Type | Field and Description |
---|---|
protected LogicalType[] |
RowDataPartitionComputer.partitionTypes |
Constructor and Description |
---|
DeferredObjectAdapter(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
LogicalType logicalType,
HiveShim hiveShim) |
Modifier and Type | Method and Description |
---|---|
static HiveObjectConversion |
HiveInspectors.getConversion(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
LogicalType dataType,
HiveShim hiveShim)
Get conversion for converting Flink object to Hive object from an ObjectInspector and the
corresponding Flink DataType.
|
Modifier and Type | Method and Description |
---|---|
static ResolvedExpression |
DeclarativeExpressionResolver.toRexDistinctKey(org.apache.calcite.tools.RelBuilder builder,
String name,
LogicalType t) |
static ResolvedExpression |
DeclarativeExpressionResolver.toRexInputRef(org.apache.calcite.tools.RelBuilder builder,
int i,
LogicalType t) |
Modifier and Type | Field and Description |
---|---|
protected LogicalType[] |
RankLikeAggFunctionBase.orderKeyTypes |
Modifier and Type | Method and Description |
---|---|
protected Expression |
RankLikeAggFunctionBase.generateInitLiteral(LogicalType orderType) |
Constructor and Description |
---|
DenseRankAggFunction(LogicalType[] orderKeyTypes) |
RankAggFunction(LogicalType[] orderKeyTypes) |
RankLikeAggFunctionBase(LogicalType[] orderKeyTypes) |
Modifier and Type | Method and Description |
---|---|
static Serializable |
HiveFunctionUtils.invokeSetArgs(Serializable function,
Object[] constantArguments,
LogicalType[] argTypes) |
ScalarFunction |
HiveScalarSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
TableFunction |
HiveTableSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
AggregateFunction |
HiveAggSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static ColumnVector |
ArrowUtils.createColumnVector(org.apache.arrow.vector.ValueVector vector,
LogicalType fieldType) |
static ArrowFieldReader |
ArrowUtils.createRowArrowFieldReader(org.apache.arrow.vector.ValueVector vector,
LogicalType fieldType) |
Constructor and Description |
---|
ArrayFieldReader(org.apache.arrow.vector.complex.ListVector listVector,
ArrowFieldReader arrayData,
LogicalType elementType) |
Constructor and Description |
---|
BytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes) |
BytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes) |
BytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes,
boolean inferBucketMemory) |
BytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes,
boolean inferBucketMemory) |
GroupAggFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateUpdateBefore)
Creates a
GroupAggFunction . |
GroupTableAggFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedTableAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateUpdateBefore)
Creates a
GroupTableAggFunction . |
MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler,
GeneratedAggsHandleFunction genGlobalAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateUpdateBefore)
Creates a
MiniBatchGlobalGroupAggFunction . |
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
RowType inputType,
int indexOfCountStar,
boolean generateUpdateBefore)
Creates a
MiniBatchGroupAggFunction . |
Constructor and Description |
---|
AbstractRowTimeUnboundedPrecedingOver(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
AbstractRowTimeUnboundedPrecedingOver(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
ProcTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingTimeBoundary) |
ProcTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingTimeBoundary) |
ProcTimeRowsBoundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset) |
ProcTimeRowsBoundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset) |
ProcTimeUnboundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes) |
RowTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset,
int rowTimeIdx) |
RowTimeRangeBoundedPrecedingFunction(GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset,
int rowTimeIdx) |
RowTimeRangeUnboundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
RowTimeRangeUnboundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
RowTimeRowsBoundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset,
int rowTimeIdx) |
RowTimeRowsBoundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset,
int rowTimeIdx) |
RowTimeRowsUnboundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
RowTimeRowsUnboundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
Modifier and Type | Field and Description |
---|---|
protected LogicalType[] |
WindowOperatorBuilder.accumulatorTypes |
protected LogicalType[] |
WindowOperatorBuilder.aggResultTypes |
protected LogicalType[] |
WindowOperatorBuilder.inputFieldTypes |
protected LogicalType[] |
WindowOperatorBuilder.windowPropertyTypes |
Modifier and Type | Method and Description |
---|---|
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
protected void |
WindowOperatorBuilder.aggregate(LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
protected void |
WindowOperatorBuilder.aggregate(LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
protected void |
WindowOperatorBuilder.aggregate(LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceTableAggsHandleFunction<?> tableAggregateFunction,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceTableAggsHandleFunction<?> tableAggregateFunction,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder.TableAggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceTableAggsHandleFunction<?> tableAggregateFunction,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.withInputFields(LogicalType[] inputFieldTypes) |
Modifier and Type | Method and Description |
---|---|
static LogicalType |
LogicalTypeDataTypeConverter.fromDataTypeToLogicalType(DataType dataType)
Deprecated.
It convert
LegacyTypeInformationType to planner types. |
static LogicalType |
TypeInfoLogicalTypeConverter.fromTypeInfoToLogicalType(TypeInformation typeInfo)
Deprecated.
It will lose some information.
|
static LogicalType |
PlannerTypeUtils.removeLegacyTypes(LogicalType t)
A conversion that removes all
LegacyTypeInformationType s by mapping to corresponding
new types. |
Modifier and Type | Method and Description |
---|---|
static TypeSerializer<?> |
InternalSerializers.create(LogicalType type)
Creates a
TypeSerializer for internal data structures of the given LogicalType . |
static TypeSerializer |
InternalSerializers.create(LogicalType type,
ExecutionConfig config)
Creates a
TypeSerializer for internal data structures of the given LogicalType . |
static DataType |
LogicalTypeDataTypeConverter.fromLogicalTypeToDataType(LogicalType logicalType)
Deprecated.
|
static TypeInformation |
TypeInfoLogicalTypeConverter.fromLogicalTypeToTypeInfo(LogicalType type)
Deprecated.
Use
BigDecimalTypeInfo to retain precision and scale of decimal. |
static int |
PlannerTypeUtils.getArity(LogicalType t)
Gets the arity of the type.
|
static Class |
ClassLogicalTypeConverter.getDefaultExternalClassForType(LogicalType type)
Deprecated.
|
static boolean |
PlannerTypeUtils.isAssignable(LogicalType t1,
LogicalType t2)
Now in the conversion to the TypeInformation from DataType, type may loose some information
about nullable and precision.
|
static boolean |
PlannerTypeUtils.isInteroperable(LogicalType t1,
LogicalType t2)
Can the two types operate with each other.
|
static boolean |
PlannerTypeUtils.isPrimitive(LogicalType type) |
static LogicalType |
PlannerTypeUtils.removeLegacyTypes(LogicalType t)
A conversion that removes all
LegacyTypeInformationType s by mapping to corresponding
new types. |
static RowType |
PlannerTypeUtils.toRowType(LogicalType t) |
Constructor and Description |
---|
DataTypePrecisionFixer(LogicalType logicalType)
Creates a new instance with the given logical type.
|
Modifier and Type | Method and Description |
---|---|
LogicalType[] |
RowDataTypeInfo.getLogicalTypes() |
Modifier and Type | Method and Description |
---|---|
protected Class |
PythonTypeUtils.LogicalTypeToConversionClassConverter.defaultMethod(LogicalType logicalType) |
protected FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.defaultMethod(LogicalType logicalType) |
static boolean |
TypeCheckUtils.isArray(LogicalType type) |
static boolean |
TypeCheckUtils.isBinaryString(LogicalType type) |
static boolean |
TypeCheckUtils.isBoolean(LogicalType type) |
static boolean |
TypeCheckUtils.isCharacterString(LogicalType type) |
static boolean |
TypeCheckUtils.isComparable(LogicalType type) |
static boolean |
TypeCheckUtils.isDecimal(LogicalType type) |
static boolean |
TypeCheckUtils.isInteger(LogicalType type) |
static boolean |
TypeCheckUtils.isLong(LogicalType type) |
static boolean |
TypeCheckUtils.isMap(LogicalType type) |
static boolean |
TypeCheckUtils.isMutable(LogicalType type) |
static boolean |
TypeCheckUtils.isNumeric(LogicalType type) |
static boolean |
TypeCheckUtils.isProcTime(LogicalType type) |
static boolean |
TypeCheckUtils.isRaw(LogicalType type) |
static boolean |
TypeCheckUtils.isReference(LogicalType type) |
static boolean |
TypeCheckUtils.isRow(LogicalType type) |
static boolean |
TypeCheckUtils.isRowTime(LogicalType type) |
static boolean |
TypeCheckUtils.isTemporal(LogicalType type) |
static boolean |
TypeCheckUtils.isTimeInterval(LogicalType type) |
static boolean |
TypeCheckUtils.isTimePoint(LogicalType type) |
static boolean |
TypeCheckUtils.isTimestamp(LogicalType type) |
static boolean |
TypeCheckUtils.isTimestampWithLocalZone(LogicalType type) |
static TypeSerializer |
PythonTypeUtils.toBlinkTypeSerializer(LogicalType logicalType) |
static TypeSerializer |
PythonTypeUtils.toFlinkTypeSerializer(LogicalType logicalType) |
Constructor and Description |
---|
ArrayDataSerializer(LogicalType eleType,
ExecutionConfig conf) |
MapDataSerializer(LogicalType keyType,
LogicalType valueType,
ExecutionConfig conf) |
RowDataSerializer(ExecutionConfig config,
LogicalType... types) |
RowDataSerializer(LogicalType[] types,
TypeSerializer<?>[] fieldSerializers) |
RowDataTypeInfo(LogicalType... logicalTypes) |
RowDataTypeInfo(LogicalType[] logicalTypes,
String[] fieldNames) |
Constructor and Description |
---|
ArrayDataSerializer(LogicalType eleType,
TypeSerializer elementTypeSerializer) |
MapDataSerializer(LogicalType keyType,
LogicalType valueType,
TypeSerializer keyTypeSerializer,
TypeSerializer valueTypeSerializer) |
RowDataSerializer(LogicalType[] types,
TypeSerializer[] fieldSerializers) |
Modifier and Type | Method and Description |
---|---|
static List<LogicalType> |
CsvTableSourceFactoryBase.getFieldLogicalTypes(TableSchema schema) |
Modifier and Type | Field and Description |
---|---|
protected LogicalType |
DataType.logicalType |
Modifier and Type | Method and Description |
---|---|
LogicalType |
DataType.getLogicalType()
Returns the corresponding logical type.
|
Constructor and Description |
---|
AtomicDataType(LogicalType logicalType) |
AtomicDataType(LogicalType logicalType,
Class<?> conversionClass) |
CollectionDataType(LogicalType logicalType,
Class<?> conversionClass,
DataType elementDataType) |
CollectionDataType(LogicalType logicalType,
DataType elementDataType) |
FieldsDataType(LogicalType logicalType,
Class<?> conversionClass,
List<DataType> fieldDataTypes) |
FieldsDataType(LogicalType logicalType,
List<DataType> fieldDataTypes) |
KeyValueDataType(LogicalType logicalType,
Class<?> conversionClass,
DataType keyDataType,
DataType valueDataType) |
KeyValueDataType(LogicalType logicalType,
DataType keyDataType,
DataType valueDataType) |
Modifier and Type | Class and Description |
---|---|
class |
ArrayType
Logical type of an array of elements with same subtype.
|
class |
BigIntType
Logical 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.
|
class |
BinaryType
Logical type of a fixed-length binary string (=a sequence of bytes).
|
class |
BooleanType
Logical type of a boolean with a (possibly) three-valued logic of
TRUE, FALSE, UNKNOWN . |
class |
CharType
Logical type of a fixed-length character string.
|
class |
DateType
Logical type of a date consisting of
year-month-day with values ranging from 0000-01-01 to 9999-12-31 . |
class |
DayTimeIntervalType
Logical type for a group of day-time interval types.
|
class |
DecimalType
Logical type of a decimal number with fixed precision and scale.
|
class |
DistinctType
Logical type of a user-defined distinct type.
|
class |
DoubleType
Logical type of an 8-byte double precision floating point number.
|
class |
FloatType
Logical type of a 4-byte single precision floating point number.
|
class |
IntType
Logical type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
|
class |
LegacyTypeInformationType<T>
This type is a temporary solution to fully support the old type system stack through the new
stack.
|
class |
LocalZonedTimestampType
Logical type of a timestamp WITH LOCAL time zone consisting of
year-month-day
hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from
0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59 . |
class |
MapType
Logical type of an associative array that maps keys (including
NULL ) to values (including
NULL ). |
class |
MultisetType
Logical type of a multiset (=bag).
|
class |
NullType
Logical type for representing untyped
NULL values. |
class |
RawType<T>
Logical type of an arbitrary serialized type.
|
class |
RowType
Logical type of a sequence of fields.
|
class |
SmallIntType
Logical type of a 2-byte signed integer with values from -32,768 to 32,767.
|
class |
StructuredType
Logical type of a user-defined object structured type.
|
class |
SymbolType<T extends TableSymbol>
Logical type for representing symbol values.
|
class |
TimestampType
Logical type of a timestamp WITHOUT time zone consisting of
year-month-day
hour:minute:second[.fractional] with up to nanosecond precision and values ranging from 0000-01-01 00:00:00.000000000 to 9999-12-31 23:59:59.999999999 . |
class |
TimeType
Logical type of a time WITHOUT time zone consisting of
hour:minute:second[.fractional]
with up to nanosecond precision and values ranging from 00:00:00.000000000 to 23:59:59.999999999 . |
class |
TinyIntType
Logical type of a 1-byte signed integer with values from -128 to 127.
|
class |
TypeInformationRawType<T>
Deprecated.
Use
RawType instead. |
class |
UnresolvedUserDefinedType
Placeholder type of an unresolved user-defined type that is identified by an
UnresolvedIdentifier . |
class |
UserDefinedType
Logical type of a user-defined representation for one or more built-in types.
|
class |
VarBinaryType
Logical type of a variable-length binary string (=a sequence of bytes).
|
class |
VarCharType
Logical type of a variable-length character string.
|
class |
YearMonthIntervalType
Logical type for a group of year-month interval types.
|
class |
ZonedTimestampType
Logical type of a timestamp WITH time zone consisting of
year-month-day
hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from
0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59 . |
Modifier and Type | Method and Description |
---|---|
LogicalType |
LogicalType.copy()
Returns a deep copy of this type.
|
LogicalType |
FloatType.copy(boolean isNullable) |
LogicalType |
VarBinaryType.copy(boolean isNullable) |
LogicalType |
TinyIntType.copy(boolean isNullable) |
LogicalType |
LegacyTypeInformationType.copy(boolean isNullable) |
LogicalType |
NullType.copy(boolean isNullable) |
LogicalType |
ArrayType.copy(boolean isNullable) |
LogicalType |
RowType.copy(boolean isNullable) |
LogicalType |
RawType.copy(boolean isNullable) |
abstract LogicalType |
LogicalType.copy(boolean isNullable)
Returns a deep copy of this type with possibly different nullability.
|
LogicalType |
BigIntType.copy(boolean isNullable) |
LogicalType |
VarCharType.copy(boolean isNullable) |
LogicalType |
IntType.copy(boolean isNullable) |
LogicalType |
SymbolType.copy(boolean isNullable) |
LogicalType |
TypeInformationRawType.copy(boolean isNullable)
Deprecated.
|
LogicalType |
StructuredType.copy(boolean isNullable) |
LogicalType |
TimeType.copy(boolean isNullable) |
LogicalType |
DayTimeIntervalType.copy(boolean isNullable) |
LogicalType |
DoubleType.copy(boolean isNullable) |
LogicalType |
BooleanType.copy(boolean isNullable) |
LogicalType |
LocalZonedTimestampType.copy(boolean isNullable) |
LogicalType |
SmallIntType.copy(boolean isNullable) |
LogicalType |
MultisetType.copy(boolean isNullable) |
LogicalType |
BinaryType.copy(boolean isNullable) |
LogicalType |
TimestampType.copy(boolean isNullable) |
LogicalType |
YearMonthIntervalType.copy(boolean isNullable) |
LogicalType |
ZonedTimestampType.copy(boolean isNullable) |
LogicalType |
UnresolvedUserDefinedType.copy(boolean isNullable) |
LogicalType |
MapType.copy(boolean isNullable) |
LogicalType |
DecimalType.copy(boolean isNullable) |
LogicalType |
CharType.copy(boolean isNullable) |
LogicalType |
DateType.copy(boolean isNullable) |
LogicalType |
DistinctType.copy(boolean isNullable) |
LogicalType |
ArrayType.getElementType() |
LogicalType |
MultisetType.getElementType() |
LogicalType |
MapType.getKeyType() |
LogicalType |
DistinctType.getSourceType() |
LogicalType |
RowType.RowField.getType() |
LogicalType |
StructuredType.StructuredAttribute.getType() |
LogicalType |
RowType.getTypeAt(int i) |
LogicalType |
MapType.getValueType() |
Modifier and Type | Method and Description |
---|---|
static DistinctType.Builder |
DistinctType.newBuilder(ObjectIdentifier objectIdentifier,
LogicalType sourceType)
Creates a builder for a
DistinctType . |
static RowType |
RowType.of(LogicalType... types) |
static RowType |
RowType.of(LogicalType[] types,
String[] names) |
R |
LogicalTypeVisitor.visit(LogicalType other) |
Constructor and Description |
---|
ArrayType(boolean isNullable,
LogicalType elementType) |
ArrayType(LogicalType elementType) |
Builder(ObjectIdentifier objectIdentifier,
LogicalType sourceType) |
MapType(boolean isNullable,
LogicalType keyType,
LogicalType valueType) |
MapType(LogicalType keyType,
LogicalType valueType) |
MultisetType(boolean isNullable,
LogicalType elementType) |
MultisetType(LogicalType elementType) |
RowField(String name,
LogicalType type) |
RowField(String name,
LogicalType type,
String description) |
StructuredAttribute(String name,
LogicalType type) |
StructuredAttribute(String name,
LogicalType type,
String description) |
Modifier and Type | Method and Description |
---|---|
protected LogicalType |
LogicalTypeDuplicator.defaultMethod(LogicalType logicalType) |
static LogicalType |
LogicalTypeParser.parse(String typeString)
Parses a type string.
|
static LogicalType |
LogicalTypeParser.parse(String typeString,
ClassLoader classLoader)
Parses a type string.
|
static LogicalType |
LogicalTypeUtils.removeTimeAttributes(LogicalType logicalType) |
LogicalType |
LogicalTypeDuplicator.visit(ArrayType arrayType) |
LogicalType |
LogicalTypeDuplicator.visit(DistinctType distinctType) |
LogicalType |
LogicalTypeDuplicator.visit(MapType mapType) |
LogicalType |
LogicalTypeDuplicator.visit(MultisetType multisetType) |
LogicalType |
LogicalTypeDuplicator.visit(RowType rowType) |
LogicalType |
LogicalTypeDuplicator.visit(StructuredType structuredType) |
Modifier and Type | Method and Description |
---|---|
static Optional<LogicalType> |
LogicalTypeGeneralization.findCommonType(List<LogicalType> types)
Returns the most common type of a set of types.
|
static List<LogicalType> |
LogicalTypeChecks.getFieldTypes(LogicalType logicalType)
Returns the field types of row and structured types.
|
Modifier and Type | Method and Description |
---|---|
protected abstract R |
LogicalTypeDefaultVisitor.defaultMethod(LogicalType logicalType) |
protected LogicalType |
LogicalTypeDuplicator.defaultMethod(LogicalType logicalType) |
static int |
LogicalTypeChecks.getDayPrecision(LogicalType logicalType) |
static int |
LogicalTypeChecks.getFieldCount(LogicalType logicalType)
Returns the field count of row and structured types.
|
static List<String> |
LogicalTypeChecks.getFieldNames(LogicalType logicalType)
Returns the field names of row and structured types.
|
static List<LogicalType> |
LogicalTypeChecks.getFieldTypes(LogicalType logicalType)
Returns the field types of row and structured types.
|
static int |
LogicalTypeChecks.getFractionalPrecision(LogicalType logicalType) |
static int |
LogicalTypeChecks.getLength(LogicalType logicalType) |
static int |
LogicalTypeChecks.getPrecision(LogicalType logicalType)
Returns the precision of all types that define a precision implicitly or explicitly.
|
static int |
LogicalTypeChecks.getScale(LogicalType logicalType)
Returns the scale of all types that define a scale implicitly or explicitly.
|
static int |
LogicalTypeChecks.getYearPrecision(LogicalType logicalType) |
static boolean |
LogicalTypeChecks.hasDayPrecision(LogicalType logicalType,
int yearPrecision) |
static boolean |
LogicalTypeChecks.hasFamily(LogicalType logicalType,
LogicalTypeFamily family) |
static boolean |
LogicalTypeChecks.hasFractionalPrecision(LogicalType logicalType,
int fractionalPrecision) |
static boolean |
LogicalTypeChecks.hasLength(LogicalType logicalType,
int length) |
static boolean |
LogicalTypeChecks.hasNestedRoot(LogicalType logicalType,
LogicalTypeRoot typeRoot)
Checks whether a (possibly nested) logical type contains the given root.
|
static boolean |
LogicalTypeChecks.hasPrecision(LogicalType logicalType,
int precision)
Checks the precision of a type that defines a precision implicitly or explicitly.
|
static boolean |
LogicalTypeChecks.hasRoot(LogicalType logicalType,
LogicalTypeRoot typeRoot) |
static boolean |
LogicalTypeChecks.hasScale(LogicalType logicalType,
int scale)
Checks the scale of all types that define a scale implicitly or explicitly.
|
static boolean |
LogicalTypeChecks.hasYearPrecision(LogicalType logicalType,
int yearPrecision) |
static boolean |
LogicalTypeChecks.isCompositeType(LogicalType logicalType)
Checks if the given type is a composite type.
|
static boolean |
LogicalTypeChecks.isProctimeAttribute(LogicalType logicalType) |
static boolean |
LogicalTypeChecks.isRowtimeAttribute(LogicalType logicalType) |
static boolean |
LogicalTypeChecks.isSingleFieldInterval(LogicalType logicalType) |
static boolean |
LogicalTypeChecks.isTimeAttribute(LogicalType logicalType) |
static LogicalType |
LogicalTypeUtils.removeTimeAttributes(LogicalType logicalType) |
static boolean |
LogicalTypeCasts.supportsAvoidingCast(LogicalType sourceType,
LogicalType targetType)
Returns whether the source type can be safely interpreted as the target type.
|
static boolean |
LogicalTypeCasts.supportsExplicitCast(LogicalType sourceType,
LogicalType targetType)
Returns whether the source type can be casted to the target type.
|
static boolean |
LogicalTypeCasts.supportsImplicitCast(LogicalType sourceType,
LogicalType targetType)
Returns whether the source type can be safely casted to the target type without loosing
information.
|
static Class<?> |
LogicalTypeUtils.toInternalConversionClass(LogicalType type)
Returns the conversion class for the given
LogicalType that is used by the table
runtime as internal data structure. |
R |
LogicalTypeDefaultVisitor.visit(LogicalType other) |
Modifier and Type | Method and Description |
---|---|
static Optional<LogicalType> |
LogicalTypeGeneralization.findCommonType(List<LogicalType> types)
Returns the most common type of a set of types.
|
static boolean |
LogicalTypeCasts.supportsAvoidingCast(List<LogicalType> sourceTypes,
List<LogicalType> targetTypes)
|
static boolean |
LogicalTypeCasts.supportsAvoidingCast(List<LogicalType> sourceTypes,
List<LogicalType> targetTypes)
|
Modifier and Type | Method and Description |
---|---|
static LogicalType |
TypeConversions.fromDataToLogicalType(DataType dataType) |
static LogicalType[] |
TypeConversions.fromDataToLogicalType(DataType[] dataTypes) |
static LogicalType |
LogicalTypeDataTypeConverter.toLogicalType(DataType dataType)
Returns the logical type of a data type.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static void |
TypeMappingUtils.checkPhysicalLogicalTypeCompatible(LogicalType physicalFieldType,
LogicalType logicalFieldType,
String physicalFieldName,
String logicalFieldName,
boolean isSource)
Checks whether the given physical field type and logical field type are compatible at the
edges of the table ecosystem.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.