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) |
org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter |
PostgresRowConverter.createInternalConverter(LogicalType type) |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcDeserializationConverter |
AbstractJdbcRowConverter.createInternalConverter(LogicalType type) |
protected org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.JdbcSerializationConverter |
PostgresRowConverter.createNullableExternalConverter(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.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 Object |
HivePartitionUtils.restorePartitionValueFromType(HiveShim shim,
String valStr,
LogicalType partitionType,
String defaultPartitionName) |
Modifier and Type | Method and Description |
---|---|
static RowDataToAvroConverters.RowDataToAvroConverter |
RowDataToAvroConverters.createConverter(LogicalType type)
Creates a runtime converter accroding to the given logical type that converts objects of
Flink Table & SQL internal data structures to corresponding Avro data structures.
|
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 schema)
Converts Flink SQL
LogicalType (can be nested) into an Avro schema. |
static org.apache.avro.Schema |
AvroSchemaConverter.convertToSchema(LogicalType logicalType,
String rowName)
Converts Flink SQL
LogicalType (can be nested) into an Avro schema. |
static LogicalType |
AvroSchemaConverter.extractValueTypeToAvroMap(LogicalType type) |
Modifier and Type | Method and Description |
---|---|
JsonToRowDataConverters.JsonToRowDataConverter |
JsonToRowDataConverters.createConverter(LogicalType type)
Creates a runtime converter which is null safe.
|
RowDataToJsonConverters.RowDataToJsonConverter |
RowDataToJsonConverters.createConverter(LogicalType type)
Creates a runtime converter which is null safe.
|
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 ColumnVector |
ParquetSplitReaderUtil.createVectorFromConstant(LogicalType type,
Object value,
int batchSize) |
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.convertToOrcTypeWithPart(String[] fullFieldNames,
LogicalType[] fullFieldTypes,
Collection<String> partitionKeys) |
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> |
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. |
BulkWriter.Factory<RowData> |
HiveShimV200.createOrcBulkWriterFactory(Configuration conf,
String schema,
LogicalType[] fieldTypes) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo |
HiveTypeUtil.toHiveTypeInfo(LogicalType logicalType,
boolean checkPrecision)
Convert Flink LogicalType to Hive TypeInfo.
|
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.
|
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)
|
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. |
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
Parser.parseSqlExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType)
Entry point for parsing SQL expressions expressed as a String.
|
Constructor and Description |
---|
ChangelogCsvDeserializer(List<LogicalType> parsingTypes,
DynamicTableSource.DataStructureConverter converter,
TypeInformation<RowData> producedTypeInfo,
String columnDelimiter) |
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
SqlExpressionResolver.resolveExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType)
Translates the given SQL expression string or throws a
ValidationException . |
Modifier and Type | Method and Description |
---|---|
protected DataGeneratorContainer |
DataGenVisitorBase.defaultMethod(LogicalType logicalType) |
protected DataGeneratorContainer |
RandomGeneratorVisitor.defaultMethod(LogicalType logicalType) |
Modifier and Type | Field and Description |
---|---|
protected LogicalType[] |
RowDataPartitionComputer.partitionTypes |
Modifier and Type | Method and Description |
---|---|
Object |
PartitionFieldExtractor.extract(T split,
String fieldName,
LogicalType fieldType) |
static Object |
RowPartitionComputer.restorePartValueFromType(String valStr,
LogicalType type)
Restore partition value from string and type.
|
Constructor and Description |
---|
RawFormatDeserializationSchema(LogicalType deserializedType,
TypeInformation<RowData> producedTypeInfo,
String charsetName,
boolean isBigEndian) |
RawFormatSerializationSchema(LogicalType serializedType,
String charsetName,
boolean isBigEndian) |
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.
|
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector |
HiveInspectors.getObjectInspector(LogicalType flinkType)
Get Hive
ObjectInspector for a Flink LogicalType . |
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
ParserImpl.parseSqlExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType) |
Modifier and Type | Method and Description |
---|---|
SqlExprToRexConverter |
SqlExprToRexConverterFactory.create(RowType inputRowType,
LogicalType outputType)
Creates a new instance of
SqlExprToRexConverter to convert SQL expression to RexNode . |
Modifier and Type | Method and Description |
---|---|
ResolvedExpression |
ParserImpl.parseSqlExpression(String sqlExpression,
RowType inputRowType,
LogicalType outputType) |
Modifier and Type | Method and Description |
---|---|
LogicalType |
PlannerWindowProperty.getResultType() |
LogicalType |
PlannerWindowStart.getResultType() |
LogicalType |
PlannerProctimeAttribute.getResultType() |
LogicalType |
PlannerWindowEnd.getResultType() |
LogicalType |
PlannerRowtimeAttribute.getResultType() |
LogicalType |
PlannerSliceEnd.getResultType() |
Modifier and Type | Method and Description |
---|---|
Optional<LogicalType> |
PlannerWindowReference.getType() |
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) |
Constructor and Description |
---|
PlannerWindowReference(String name,
LogicalType type) |
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 |
---|
CollectAggFunction(LogicalType elementType) |
DenseRankAggFunction(LogicalType[] orderKeyTypes) |
FirstValueAggFunction(LogicalType valueType) |
FirstValueWithRetractAggFunction(LogicalType valueType) |
LagAggFunction(LogicalType[] valueTypes) |
LastValueAggFunction(LogicalType valueType) |
LastValueWithRetractAggFunction(LogicalType valueType) |
MaxWithRetractAggFunction(LogicalType valueType) |
MinWithRetractAggFunction(LogicalType valueType) |
RankAggFunction(LogicalType[] orderKeyTypes) |
RankLikeAggFunctionBase(LogicalType[] orderKeyTypes) |
Constructor and Description |
---|
LookupCallContext(DataTypeFactory dataTypeFactory,
UserDefinedFunction function,
LogicalType inputType,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
int[] lookupKeyOrder,
LogicalType lookupType) |
Modifier and Type | Method and Description |
---|---|
AggregateFunction |
HiveAggSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
TableFunction |
HiveTableSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
Constructor and Description |
---|
WritingMetadataSpec(List<String> metadataKeys,
LogicalType consumedType) |
Modifier and Type | Field and Description |
---|---|
protected LogicalType |
WindowingStrategy.timeAttributeType |
Modifier and Type | Method and Description |
---|---|
LogicalType |
WindowingStrategy.getTimeAttributeType() |
Constructor and Description |
---|
SliceAttachedWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int sliceEnd) |
TimeAttributeWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int timeAttributeIndex) |
WindowAttachedWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int windowEnd)
Creates a
WindowAttachedWindowingStrategy which only WindowAttachedWindowingStrategy.windowEnd is attatched. |
WindowAttachedWindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
int windowStart,
int windowEnd) |
WindowingStrategy(WindowSpec window,
LogicalType timeAttributeType) |
WindowingStrategy(WindowSpec window,
LogicalType timeAttributeType,
boolean isRowtime) |
Modifier and Type | Method and Description |
---|---|
LogicalType |
ExecEdge.getOutputType()
Returns the output
LogicalType of the data passing this edge. |
LogicalType |
ExecNode.getOutputType()
Returns the output
LogicalType of this node, this type should be consistent with the
type parameter T . |
LogicalType |
ExecNodeBase.getOutputType() |
Constructor and Description |
---|
ExecNodeBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
ExecNodeBase(List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Constructor and Description |
---|
BatchExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecLimit(long limitStart,
long limitEnd,
boolean isGlobal,
InputProperty inputProperty,
LogicalType outputType,
String description) |
BatchExecSink(DynamicTableSinkSpec tableSinkSpec,
InputProperty inputProperty,
LogicalType outputType,
String description) |
Constructor and Description |
---|
CommonExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
boolean isStreaming,
InputProperty inputProperty,
LogicalType outputType,
String description) |
CommonExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode changelogMode,
boolean isBounded,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
CommonExecTableSourceScan(DynamicTableSourceSpec tableSourceSpec,
int id,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
LogicalType |
LogicalTypeJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode logicalTypeNode,
SerdeContext serdeCtx) |
LogicalType |
LogicalTypeJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
LogicalTypeJsonSerializer.serialize(LogicalType logicalType,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator jsonGenerator,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider serializerProvider) |
Modifier and Type | Method and Description |
---|---|
LogicalType[] |
SortSpec.getFieldTypes(RowType input)
Gets fields types of sort fields accoording to input type.
|
Modifier and Type | Method and Description |
---|---|
protected LogicalType[] |
StreamExecWindowAggregateBase.convertToLogicalTypes(DataType[] dataTypes) |
Constructor and Description |
---|
StreamExecAggregateBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
StreamExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
InputProperty inputProperty,
LogicalType outputType,
String description) |
StreamExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
StreamExecSink(DynamicTableSinkSpec tableSinkSpec,
ChangelogMode inputChangelogMode,
int id,
List<InputProperty> inputProperties,
LogicalType outputType,
boolean upsertMaterialize,
String description) |
StreamExecWindowAggregateBase(int id,
List<InputProperty> inputProperties,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
LogicalType |
RelWindowProperties.getTimeAttributeType() |
Modifier and Type | Method and Description |
---|---|
static RelWindowProperties |
RelWindowProperties.create(org.apache.calcite.util.ImmutableBitSet windowStartColumns,
org.apache.calcite.util.ImmutableBitSet windowEndColumns,
org.apache.calcite.util.ImmutableBitSet windowTimeColumns,
WindowSpec windowSpec,
LogicalType timeAttributeType)
Creates a
RelWindowProperties , may return null if the window properties can't be
propagated (loss window start and window end columns). |
Modifier and Type | Field and Description |
---|---|
LogicalType |
LookupJoinUtil.ConstantLookupKey.sourceType |
Constructor and Description |
---|
ConstantLookupKey(LogicalType sourceType,
RexLiteral literal) |
Modifier and Type | Method and Description |
---|---|
static boolean |
DataViewUtils.isDataView(LogicalType t,
Class<? extends DataView> viewClass) |
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) |
Modifier and Type | Method and Description |
---|---|
LogicalType |
SqlUnnestUtils.UnnestTableFunction.getWrappedOutputType() |
Modifier and Type | Method and Description |
---|---|
static SqlUnnestUtils.UnnestTableFunction |
SqlUnnestUtils.createUnnestFunction(LogicalType t) |
Constructor and Description |
---|
CollectionUnnestTableFunction(LogicalType inputType,
LogicalType outputType,
ArrayData.ElementGetter elementGetter) |
MapUnnestTableFunction(LogicalType inputType,
LogicalType outputType,
ArrayData.ElementGetter keyGetter,
ArrayData.ElementGetter valueGetter) |
Constructor and Description |
---|
GroupAggFunction(GeneratedAggsHandleFunction genAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateUpdateBefore,
long stateRetentionTime)
Creates a
GroupAggFunction . |
GroupTableAggFunction(GeneratedTableAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateUpdateBefore,
long stateRetentionTime)
Creates a
GroupTableAggFunction . |
MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler,
GeneratedAggsHandleFunction genGlobalAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
int indexOfCountStar,
boolean generateUpdateBefore,
long stateRetentionTime)
Creates a
MiniBatchGlobalGroupAggFunction . |
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler,
GeneratedRecordEqualiser genRecordEqualiser,
LogicalType[] accTypes,
RowType inputType,
int indexOfCountStar,
boolean generateUpdateBefore,
long stateRetentionTime)
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) |
Constructor and Description |
---|
ComparableRecordComparator(GeneratedRecordComparator generatedRecordComparator,
int[] compareKeyPositions,
LogicalType[] compareKeyTypes,
boolean[] compareOrders,
boolean[] nullsIsLast) |
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.
|
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 DataType |
LogicalTypeDataTypeConverter.fromLogicalTypeToDataType(LogicalType logicalType)
Deprecated.
|
static TypeInformation |
TypeInfoLogicalTypeConverter.fromLogicalTypeToTypeInfo(LogicalType type)
Deprecated.
Use
BigDecimalTypeInfo to retain precision and scale of decimal. |
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. |
Constructor and Description |
---|
DataTypePrecisionFixer(LogicalType logicalType)
Creates a new instance with the given logical type.
|
Modifier and Type | Method and Description |
---|---|
LogicalType |
InternalTypeInfo.toLogicalType() |
LogicalType[] |
InternalTypeInfo.toRowFieldTypes()
Deprecated.
TypeInformation should just be a thin wrapper of a serializer. This
method only exists for legacy code. It is recommended to use the RowType instead
for logical operations. |
Modifier and Type | Method and Description |
---|---|
static <T> TypeSerializer<T> |
InternalSerializers.create(LogicalType type)
Creates a
TypeSerializer for internal data structures of the given LogicalType . |
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.isMultiset(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 <T> InternalTypeInfo<T> |
InternalTypeInfo.of(LogicalType type)
Creates type information for a
LogicalType that is represented by internal data
structures. |
static InternalTypeInfo<RowData> |
InternalTypeInfo.ofFields(LogicalType... fieldTypes)
Creates type information for
RowType represented by internal data structures. |
static InternalTypeInfo<RowData> |
InternalTypeInfo.ofFields(LogicalType[] fieldTypes,
String[] fieldNames)
Creates type information for
RowType represented by internal data structures. |
static TypeSerializer |
PythonTypeUtils.toBlinkTypeSerializer(LogicalType logicalType) |
static TypeSerializer |
PythonTypeUtils.toFlinkTypeSerializer(LogicalType logicalType) |
static FlinkFnApi.Schema.FieldType |
PythonTypeUtils.toProtoType(LogicalType logicalType) |
Constructor and Description |
---|
ArrayDataSerializer(LogicalType eleType) |
MapDataSerializer(LogicalType keyType,
LogicalType valueType) |
RowDataSerializer(LogicalType... types) |
RowDataSerializer(LogicalType[] types,
TypeSerializer<?>[] fieldSerializers) |
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 java.time.ZoneId |
TimeWindowUtil.getShiftTimeZone(LogicalType timeAttributeType,
TableConfig tableConfig)
Get the shifted timezone of window if the time attribute type is TIMESTAMP_LTZ, always
returns UTC timezone if the time attribute type is TIMESTAMP which means do not shift.
|
Constructor and Description |
---|
AbstractBytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<K> keySerializer,
LogicalType[] valueTypes) |
AbstractBytesMultiMap(Object owner,
MemoryManager memoryManager,
long memorySize,
PagedTypeSerializer<K> keySerializer,
LogicalType[] valueTypes) |
BytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes) |
BytesHashMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes) |
BytesMultiMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes) |
BytesMultiMap(Object owner,
MemoryManager memoryManager,
long memorySize,
LogicalType[] keyTypes,
LogicalType[] valueTypes) |
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 | Method and Description |
---|---|
static TypeStrategy |
TypeStrategies.aggArg0(java.util.function.Function<LogicalType,LogicalType> aggType,
boolean nullableIfGroupingEmpty)
Type strategy specific for aggregations that partially produce different nullability
depending whether the result is grouped or not.
|
static TypeStrategy |
TypeStrategies.aggArg0(java.util.function.Function<LogicalType,LogicalType> aggType,
boolean nullableIfGroupingEmpty)
Type strategy specific for aggregations that partially produce different nullability
depending whether the result is grouped or not.
|
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 |
BooleanType.copy(boolean isNullable) |
LogicalType |
TimeType.copy(boolean isNullable) |
LogicalType |
ArrayType.copy(boolean isNullable) |
LogicalType |
VarBinaryType.copy(boolean isNullable) |
LogicalType |
MapType.copy(boolean isNullable) |
LogicalType |
DateType.copy(boolean isNullable) |
LogicalType |
BinaryType.copy(boolean isNullable) |
LogicalType |
SymbolType.copy(boolean isNullable) |
LogicalType |
DoubleType.copy(boolean isNullable) |
LogicalType |
CharType.copy(boolean isNullable) |
LogicalType |
StructuredType.copy(boolean isNullable) |
LogicalType |
DecimalType.copy(boolean isNullable) |
LogicalType |
YearMonthIntervalType.copy(boolean isNullable) |
LogicalType |
IntType.copy(boolean isNullable) |
LogicalType |
TimestampType.copy(boolean isNullable) |
LogicalType |
ZonedTimestampType.copy(boolean isNullable) |
LogicalType |
LegacyTypeInformationType.copy(boolean isNullable) |
LogicalType |
RowType.copy(boolean isNullable) |
LogicalType |
BigIntType.copy(boolean isNullable) |
LogicalType |
FloatType.copy(boolean isNullable) |
LogicalType |
DistinctType.copy(boolean isNullable) |
LogicalType |
LocalZonedTimestampType.copy(boolean isNullable) |
LogicalType |
NullType.copy(boolean isNullable) |
LogicalType |
SmallIntType.copy(boolean isNullable) |
LogicalType |
TinyIntType.copy(boolean isNullable) |
abstract LogicalType |
LogicalType.copy(boolean isNullable)
Returns a deep copy of this type with possibly different nullability.
|
LogicalType |
MultisetType.copy(boolean isNullable) |
LogicalType |
VarCharType.copy(boolean isNullable) |
LogicalType |
TypeInformationRawType.copy(boolean isNullable)
Deprecated.
|
LogicalType |
RawType.copy(boolean isNullable) |
LogicalType |
DayTimeIntervalType.copy(boolean isNullable) |
LogicalType |
UnresolvedUserDefinedType.copy(boolean isNullable) |
LogicalType |
ArrayType.getElementType() |
LogicalType |
MultisetType.getElementType() |
LogicalType |
MapType.getKeyType() |
LogicalType |
DistinctType.getSourceType() |
LogicalType |
StructuredType.StructuredAttribute.getType() |
LogicalType |
RowType.RowField.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(boolean isNullable,
LogicalType... types) |
static RowType |
RowType.of(boolean nullable,
LogicalType[] types,
String[] names) |
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 |
LogicalTypeMerging.findAvgAggType(LogicalType argType)
Finds the result type of a decimal average aggregation.
|
static LogicalType |
LogicalTypeMerging.findSumAggType(LogicalType argType)
Finds the result type of a decimal sum aggregation.
|
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> |
LogicalTypeMerging.findCommonType(List<LogicalType> types)
Returns the most common, more general
LogicalType for a given 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 |
---|---|
static boolean |
LogicalTypeChecks.canBeTimeAttributeType(LogicalType logicalType) |
protected LogicalType |
LogicalTypeDuplicator.defaultMethod(LogicalType logicalType) |
protected abstract R |
LogicalTypeDefaultVisitor.defaultMethod(LogicalType logicalType) |
static LogicalType |
LogicalTypeMerging.findAvgAggType(LogicalType argType)
Finds the result type of a decimal average aggregation.
|
static LogicalType |
LogicalTypeMerging.findSumAggType(LogicalType argType)
Finds the result type of a decimal sum aggregation.
|
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.hasLegacyTypes(LogicalType logicalType)
Checks whether a (possibly nested) logical type contains
LegacyTypeInformationType or
TypeInformationRawType . |
static boolean |
LogicalTypeChecks.hasLength(LogicalType logicalType,
int length) |
static boolean |
LogicalTypeChecks.hasNested(LogicalType logicalType,
java.util.function.Predicate<LogicalType> predicate)
Checks whether a (possibly nested) logical type fulfills the given predicate.
|
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.hasWellDefinedString(LogicalType logicalType)
Checks whether the given
LogicalType has a well-defined string representation when
calling Object.toString() on the internal data structure. |
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. |
static RowType |
LogicalTypeUtils.toRowType(LogicalType t)
Converts any logical type to a row type.
|
R |
LogicalTypeDefaultVisitor.visit(LogicalType other) |
Modifier and Type | Method and Description |
---|---|
static Optional<LogicalType> |
LogicalTypeMerging.findCommonType(List<LogicalType> types)
Returns the most common, more general
LogicalType for a given set of types. |
static boolean |
LogicalTypeChecks.hasNested(LogicalType logicalType,
java.util.function.Predicate<LogicalType> predicate)
Checks whether a (possibly nested) logical type fulfills the given predicate.
|
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.
|
static DataType |
DataTypeUtils.toInternalDataType(LogicalType logicalType)
Creates a
DataType from the given LogicalType with internal data structures. |
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–2022 The Apache Software Foundation. All rights reserved.