Modifier and Type | Method and Description |
---|---|
static int |
BinaryArray.calculateFixLengthPartSize(LogicalType type)
It store real value when type is primitive.
|
static Object |
TypeGetterSetters.get(TypeGetterSetters row,
int ordinal,
LogicalType type) |
static boolean |
BinaryRow.isInFixedLengthPart(LogicalType type)
If it is a fixed-length field, we can call this BinaryRow's setXX method for in-place updates.
|
static boolean |
BinaryRow.isMutable(LogicalType type) |
void |
BinaryArrayWriter.setNullAt(int pos,
LogicalType type) |
<T> T[] |
BinaryArray.toClassArray(LogicalType elementType,
Class<T> elementClass) |
Map |
GenericMap.toJavaMap(LogicalType keyType,
LogicalType valueType) |
Map<Object,Object> |
BinaryMap.toJavaMap(LogicalType keyType,
LogicalType valueType) |
Map |
BaseMap.toJavaMap(LogicalType keyType,
LogicalType valueType)
This method will return a Java map containing INTERNAL type data.
|
static String |
BinaryRow.toOriginString(BaseRow row,
LogicalType[] types) |
String |
BinaryRow.toOriginString(LogicalType... types) |
static void |
BinaryWriter.write(BinaryWriter writer,
int pos,
Object o,
LogicalType type,
TypeSerializer serializer) |
Modifier and Type | Method and Description |
---|---|
static GenericRow |
BaseRowUtil.toGenericRow(BaseRow baseRow,
LogicalType[] types) |
Modifier and Type | Method and Description |
---|---|
static AbstractHeapVector[] |
AbstractHeapVector.allocateHeapVectors(LogicalType[] fieldTypes,
int maxRows) |
static AbstractHeapVector |
AbstractHeapVector.createHeapColumn(LogicalType fieldType,
int maxRows) |
Constructor and Description |
---|
DeferredObjectAdapter(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
LogicalType logicalType) |
Modifier and Type | Method and Description |
---|---|
static HiveObjectConversion |
HiveInspectors.getConversion(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
LogicalType dataType)
Get conversion for converting Flink object to Hive object from an ObjectInspector and the corresponding Flink DataType.
|
Modifier and Type | Method and Description |
---|---|
LogicalType |
ResolvedAggInputReference.getResultType() |
LogicalType |
ResolvedDistinctKeyReference.getResultType() |
LogicalType |
ResolvedAggLocalReference.getResultType() |
Constructor and Description |
---|
ResolvedAggInputReference(String name,
int index,
LogicalType resultType) |
ResolvedAggLocalReference(String fieldTerm,
String nullTerm,
LogicalType resultType) |
ResolvedDistinctKeyReference(String name,
LogicalType resultType) |
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 |
---|---|
TableFunction |
HiveTableSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
ScalarFunction |
HiveScalarSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
AggregateFunction |
HiveAggSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
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 generateRetraction)
Creates a
GroupAggFunction . |
MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler,
GeneratedAggsHandleFunction genGlobalAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateRetraction)
Creates a
MiniBatchGlobalGroupAggFunction . |
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
RowType inputType,
int indexOfCountStar,
boolean generateRetraction)
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(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingTimeBoundary) |
ProcTimeRangeBoundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
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(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
long precedingOffset,
int rowTimeIdx) |
RowTimeRangeBoundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
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 | Method and Description |
---|---|
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
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.
|
Modifier and Type | Method and Description |
---|---|
static TypeSerializer |
InternalSerializers.create(LogicalType type,
ExecutionConfig config) |
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 Class |
ClassLogicalTypeConverter.getInternalClassForType(LogicalType type)
Get internal(sql engine execution data formats) class for
LogicalType . |
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 RowType |
PlannerTypeUtils.toRowType(LogicalType t) |
Modifier and Type | Method and Description |
---|---|
LogicalType[] |
BaseRowTypeInfo.getLogicalTypes() |
Modifier and Type | Method and Description |
---|---|
static boolean |
TypeCheckUtils.isAny(LogicalType type) |
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.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) |
Constructor and Description |
---|
BaseArraySerializer(LogicalType eleType,
ExecutionConfig conf) |
BaseMapSerializer(LogicalType keyType,
LogicalType valueType,
ExecutionConfig conf) |
BaseRowSerializer(ExecutionConfig config,
LogicalType... types) |
BaseRowSerializer(LogicalType[] types,
TypeSerializer[] fieldSerializers) |
BaseRowTypeInfo(LogicalType... logicalTypes) |
BaseRowTypeInfo(LogicalType[] logicalTypes,
String[] fieldNames) |
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,
Map<String,DataType> fieldDataTypes) |
FieldsDataType(LogicalType logicalType,
Map<String,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 |
AnyType<T>
Logical type of an arbitrary serialized type.
|
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 |
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 |
TypeInformationAnyType<T>
Placeholder type of an arbitrary serialized type backed by
TypeInformation . |
class |
UnresolvedUserDefinedType
Placeholder type of an unresolved user-defined type that is identified by a partially or fully
qualified path (
[catalog].[database].[type] ). |
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 |
TinyIntType.copy(boolean isNullable) |
LogicalType |
RowType.copy(boolean isNullable) |
LogicalType |
YearMonthIntervalType.copy(boolean isNullable) |
LogicalType |
TimeType.copy(boolean isNullable) |
LogicalType |
TimestampType.copy(boolean isNullable) |
LogicalType |
AnyType.copy(boolean isNullable) |
LogicalType |
MultisetType.copy(boolean isNullable) |
LogicalType |
DistinctType.copy(boolean isNullable) |
LogicalType |
VarCharType.copy(boolean isNullable) |
LogicalType |
ZonedTimestampType.copy(boolean isNullable) |
LogicalType |
NullType.copy(boolean isNullable) |
LogicalType |
DayTimeIntervalType.copy(boolean isNullable) |
LogicalType |
CharType.copy(boolean isNullable) |
LogicalType |
VarBinaryType.copy(boolean isNullable) |
LogicalType |
DoubleType.copy(boolean isNullable) |
LogicalType |
SmallIntType.copy(boolean isNullable) |
abstract LogicalType |
LogicalType.copy(boolean isNullable)
Returns a deep copy of this type with possibly different nullability.
|
LogicalType |
ArrayType.copy(boolean isNullable) |
LogicalType |
IntType.copy(boolean isNullable) |
LogicalType |
StructuredType.copy(boolean isNullable) |
LogicalType |
BinaryType.copy(boolean isNullable) |
LogicalType |
UnresolvedUserDefinedType.copy(boolean isNullable) |
LogicalType |
SymbolType.copy(boolean isNullable) |
LogicalType |
FloatType.copy(boolean isNullable) |
LogicalType |
DecimalType.copy(boolean isNullable) |
LogicalType |
BigIntType.copy(boolean isNullable) |
LogicalType |
LegacyTypeInformationType.copy(boolean isNullable) |
LogicalType |
TypeInformationAnyType.copy(boolean isNullable) |
LogicalType |
BooleanType.copy(boolean isNullable) |
LogicalType |
DateType.copy(boolean isNullable) |
LogicalType |
MapType.copy(boolean isNullable) |
LogicalType |
LocalZonedTimestampType.copy(boolean isNullable) |
LogicalType |
MultisetType.getElementType() |
LogicalType |
ArrayType.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 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.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
LogicalTypeChecks.areTypesCompatible(LogicalType thisType,
LogicalType thatType)
Returns true if the two given types are compatible.
|
protected LogicalType |
LogicalTypeDuplicator.defaultMethod(LogicalType logicalType) |
protected abstract R |
LogicalTypeDefaultVisitor.defaultMethod(LogicalType logicalType) |
static int |
LogicalTypeChecks.getDayPrecision(LogicalType logicalType) |
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.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.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.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.
|
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.
|
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.