Modifier and Type | Method and Description |
---|---|
ResolvedSchema |
TableResult.getResolvedSchema()
Returns the schema of the result.
|
ResolvedSchema |
Table.getResolvedSchema()
Returns the resolved schema of this table.
|
ResolvedSchema |
Schema.resolve(SchemaResolver resolver)
Resolves the given
Schema to a validated ResolvedSchema . |
Modifier and Type | Method and Description |
---|---|
Schema.Builder |
Schema.Builder.fromResolvedSchema(ResolvedSchema resolvedSchema)
Adopts all members from the given resolved schema.
|
static TableSchema |
TableSchema.fromResolvedSchema(ResolvedSchema resolvedSchema)
Deprecated.
Helps to migrate to the new
ResolvedSchema to old API methods. |
Modifier and Type | Method and Description |
---|---|
ResolvedSchema |
TableImpl.getResolvedSchema() |
ResolvedSchema |
TableResultImpl.getResolvedSchema() |
Modifier and Type | Method and Description |
---|---|
TableResultImpl.Builder |
TableResultImpl.Builder.schema(ResolvedSchema resolvedSchema)
Specifies schema of the execution result.
|
Modifier and Type | Method and Description |
---|---|
ResolvedSchema |
CatalogManager.TableLookupResult.getResolvedSchema() |
ResolvedSchema |
ResolvedCatalogBaseTable.getResolvedSchema()
Returns a fully resolved and validated
ResolvedSchema . |
ResolvedSchema |
ResolvedCatalogView.getResolvedSchema() |
ResolvedSchema |
ResolvedCatalogTable.getResolvedSchema() |
static ResolvedSchema |
ResolvedSchema.of(Column... columns)
Shortcut for a resolved schema of only columns.
|
static ResolvedSchema |
ResolvedSchema.of(List<Column> columns)
Shortcut for a resolved schema of only columns.
|
static ResolvedSchema |
ResolvedSchema.physical(List<String> columnNames,
List<DataType> columnDataTypes)
Shortcut for a resolved schema of only physical columns.
|
static ResolvedSchema |
ResolvedSchema.physical(String[] columnNames,
DataType[] columnDataTypes)
Shortcut for a resolved schema of only physical columns.
|
ResolvedSchema |
SchemaResolver.resolve(Schema schema) |
Modifier and Type | Method and Description |
---|---|
static SchemaTranslator.ProducingResult |
SchemaTranslator.createProducingResult(DataTypeFactory dataTypeFactory,
ResolvedSchema inputSchema,
AbstractDataType<?> targetDataType)
Converts the given
DataType into the final SchemaTranslator.ProducingResult . |
static SchemaTranslator.ProducingResult |
SchemaTranslator.createProducingResult(ResolvedSchema inputSchema,
Schema declaredSchema)
Converts the given
DataType into the final SchemaTranslator.ProducingResult . |
Constructor and Description |
---|
ResolvedCatalogTable(CatalogTable origin,
ResolvedSchema resolvedSchema) |
ResolvedCatalogView(CatalogView origin,
ResolvedSchema resolvedSchema) |
Modifier and Type | Method and Description |
---|---|
ResolvedSchema |
ResultDescriptor.getResultSchema() |
Constructor and Description |
---|
ResultDescriptor(String resultId,
ResolvedSchema resultSchema,
boolean isMaterialized,
ReadableConfig config) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSourceUtils.convertDataStreamToRel(boolean isBatchMode,
ReadableConfig config,
org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
ObjectIdentifier identifier,
ResolvedSchema schema,
DataStream<?> dataStream,
DataType physicalDataType,
boolean isTopLevelRecord,
ChangelogMode changelogMode)
Converts a given
DataStream to a RelNode . |
static RowType |
DynamicSourceUtils.createProducedType(ResolvedSchema schema,
DynamicTableSource source)
Returns the
DataType that a source should produce as the input into the runtime. |
static List<String> |
DynamicSourceUtils.createRequiredMetadataKeys(ResolvedSchema schema,
DynamicTableSource source)
Returns a list of required metadata keys.
|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.validateSchemaAndApplyImplicitCast(org.apache.calcite.rel.RelNode query,
ResolvedSchema sinkSchema,
ObjectIdentifier sinkIdentifier,
DataTypeFactory dataTypeFactory,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory)
Checks if the given query can be written into the given sink's table schema.
|
Modifier and Type | Method and Description |
---|---|
ResolvedSchema |
PlannerQueryOperation.getResolvedSchema() |
ResolvedSchema |
DataStreamQueryOperation.getResolvedSchema() |
Constructor and Description |
---|
DataStreamQueryOperation(ObjectIdentifier identifier,
DataStream<E> dataStream,
int[] fieldIndices,
ResolvedSchema resolvedSchema,
boolean[] fieldNullables,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic) |
Modifier and Type | Method and Description |
---|---|
static ResolvedSchema |
DataTypeUtils.expandCompositeTypeToSchema(DataType dataType)
Expands a composite
DataType to a corresponding ResolvedSchema . |
Modifier and Type | Method and Description |
---|---|
ResolvedSchema |
FieldInfoUtils.TypeInfoSchema.toResolvedSchema() |
Modifier and Type | Method and Description |
---|---|
static void |
PrintUtils.printAsTableauForm(ResolvedSchema resolvedSchema,
Iterator<Row> it,
PrintWriter printWriter,
int maxColumnWidth,
String nullColumn,
boolean deriveColumnWidthByType,
boolean printRowKind,
java.time.ZoneId sessionTimeZone)
Displays the result in a tableau form.
|
static void |
PrintUtils.printAsTableauForm(ResolvedSchema resolvedSchema,
Iterator<Row> it,
PrintWriter printWriter,
java.time.ZoneId sessionTimeZone)
Displays the result in a tableau form.
|
static String[] |
PrintUtils.rowToString(Row row,
ResolvedSchema resolvedSchema,
java.time.ZoneId sessionTimeZone) |
static String[] |
PrintUtils.rowToString(Row row,
String nullColumn,
boolean printRowKind,
ResolvedSchema resolvedSchema,
java.time.ZoneId sessionTimeZone) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.