Uses of Class
org.apache.flink.table.catalog.ResolvedSchema

Packages that use ResolvedSchema

Package	Description
org.apache.flink.table.api
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.client.gateway
org.apache.flink.table.endpoint.hive
org.apache.flink.table.endpoint.hive.util
org.apache.flink.table.gateway.api
org.apache.flink.table.gateway.api.results
org.apache.flink.table.gateway.service
org.apache.flink.table.gateway.service.operation
org.apache.flink.table.gateway.service.result
org.apache.flink.table.operations
org.apache.flink.table.planner.connectors
org.apache.flink.table.planner.operations
org.apache.flink.table.types.utils
org.apache.flink.table.typeutils
org.apache.flink.table.utils.print

Uses of ResolvedSchema in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return ResolvedSchema

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.

Methods in org.apache.flink.table.api with parameters of type ResolvedSchema

Modifier and Type	Method and Description
static TableSchema	TableSchema.fromResolvedSchema(ResolvedSchema resolvedSchema) Deprecated. Helps to migrate to the new ResolvedSchema to old API methods.
Schema.Builder	Schema.Builder.fromResolvedSchema(ResolvedSchema resolvedSchema) Adopts all members from the given resolved schema.

Uses of ResolvedSchema in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	TableResultImpl.getResolvedSchema()
ResolvedSchema	TableImpl.getResolvedSchema()

Methods in org.apache.flink.table.api.internal with parameters of type ResolvedSchema

Modifier and Type	Method and Description
TableResultImpl.Builder	TableResultImpl.Builder.schema(ResolvedSchema resolvedSchema) Specifies schema of the execution result.

Uses of ResolvedSchema in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	ContextResolvedTable.getResolvedSchema()
ResolvedSchema	ResolvedCatalogTable.getResolvedSchema()
ResolvedSchema	ResolvedCatalogBaseTable.getResolvedSchema() Returns a fully resolved and validated ResolvedSchema.
ResolvedSchema	ResolvedCatalogView.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)

Methods in org.apache.flink.table.catalog with parameters of type ResolvedSchema

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.

Constructors in org.apache.flink.table.catalog with parameters of type ResolvedSchema

Constructor and Description
ResolvedCatalogTable(CatalogTable origin, ResolvedSchema resolvedSchema)
ResolvedCatalogView(CatalogView origin, ResolvedSchema resolvedSchema)

Uses of ResolvedSchema in org.apache.flink.table.client.gateway

Methods in org.apache.flink.table.client.gateway that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	ResultDescriptor.getResultSchema()

Constructors in org.apache.flink.table.client.gateway with parameters of type ResolvedSchema

Constructor and Description
ResultDescriptor(String resultId, ResolvedSchema resultSchema, boolean isMaterialized, ReadableConfig config, RowDataToStringConverter rowDataToStringConverter)

Uses of ResolvedSchema in org.apache.flink.table.endpoint.hive

Fields in org.apache.flink.table.endpoint.hive declared as ResolvedSchema

Modifier and Type	Field and Description
static ResolvedSchema	HiveServer2Schemas.GET_CATALOGS_SCHEMA Schema for HiveServer2Endpoint.GetCatalogs(org.apache.hive.service.rpc.thrift.TGetCatalogsReq).
static ResolvedSchema	HiveServer2Schemas.GET_COLUMNS_SCHEMA Schema for HiveServer2Endpoint.GetColumns(org.apache.hive.service.rpc.thrift.TGetColumnsReq).
static ResolvedSchema	HiveServer2Schemas.GET_FUNCTIONS_SCHEMA Schema for HiveServer2Endpoint.GetFunctions(org.apache.hive.service.rpc.thrift.TGetFunctionsReq).
static ResolvedSchema	HiveServer2Schemas.GET_PRIMARY_KEYS_SCHEMA Schema for HiveServer2Endpoint.GetPrimaryKeys(org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq).
static ResolvedSchema	HiveServer2Schemas.GET_SCHEMAS_SCHEMA Schema for HiveServer2Endpoint.GetSchemas(org.apache.hive.service.rpc.thrift.TGetSchemasReq).
static ResolvedSchema	HiveServer2Schemas.GET_TABLE_TYPES_SCHEMA Schema for HiveServer2Endpoint.GetTableTypes(org.apache.hive.service.rpc.thrift.TGetTableTypesReq).
static ResolvedSchema	HiveServer2Schemas.GET_TABLES_SCHEMA Schema for HiveServer2Endpoint.GetTables(org.apache.hive.service.rpc.thrift.TGetTablesReq).
static ResolvedSchema	HiveServer2Schemas.GET_TYPE_INFO_SCHEMA Schema for HiveServer2Endpoint.GetTypeInfo(org.apache.hive.service.rpc.thrift.TGetTypeInfoReq).

Uses of ResolvedSchema in org.apache.flink.table.endpoint.hive.util

Methods in org.apache.flink.table.endpoint.hive.util with parameters of type ResolvedSchema

Modifier and Type	Method and Description
static org.apache.hive.service.rpc.thrift.TRowSet	ThriftObjectConversions.toTRowSet(org.apache.hive.service.rpc.thrift.TProtocolVersion version, ResolvedSchema schema, List<RowData> data) Similar to SerDeUtils.toThriftPayload(Object, ObjectInspector, int) that converts the returned Rows to JSON string.
static org.apache.hive.service.rpc.thrift.TTableSchema	ThriftObjectConversions.toTTableSchema(ResolvedSchema schema) Similar logic in the org.apache.hive.service.cli.ColumnDescriptor.

Uses of ResolvedSchema in org.apache.flink.table.gateway.api

Methods in org.apache.flink.table.gateway.api that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	SqlGatewayService.getOperationResultSchema(SessionHandle sessionHandle, OperationHandle operationHandle) Get the result schema for the specified Operation.

Uses of ResolvedSchema in org.apache.flink.table.gateway.api.results

Methods in org.apache.flink.table.gateway.api.results that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	ResultSet.getResultSchema() The schema of the data.

Constructors in org.apache.flink.table.gateway.api.results with parameters of type ResolvedSchema

Constructor and Description
ResultSet(ResultSet.ResultType resultType, Long nextToken, ResolvedSchema resultSchema, List<RowData> data)

Uses of ResolvedSchema in org.apache.flink.table.gateway.service

Methods in org.apache.flink.table.gateway.service that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	SqlGatewayServiceImpl.getOperationResultSchema(SessionHandle sessionHandle, OperationHandle operationHandle)

Uses of ResolvedSchema in org.apache.flink.table.gateway.service.operation

Methods in org.apache.flink.table.gateway.service.operation that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	OperationManager.getOperationResultSchema(OperationHandle operationHandle) Get the ResolvedSchema of the operation.
ResolvedSchema	OperationManager.Operation.getResultSchema()

Uses of ResolvedSchema in org.apache.flink.table.gateway.service.result

Methods in org.apache.flink.table.gateway.service.result that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	ResultFetcher.getResultSchema()

Constructors in org.apache.flink.table.gateway.service.result with parameters of type ResolvedSchema

Constructor and Description
ResultFetcher(OperationHandle operationHandle, ResolvedSchema resultSchema, CloseableIterator<RowData> resultRows)
ResultFetcher(OperationHandle operationHandle, ResolvedSchema resultSchema, List<RowData> rows)

Uses of ResolvedSchema in org.apache.flink.table.operations

Methods in org.apache.flink.table.operations that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	ExternalQueryOperation.getResolvedSchema()
ResolvedSchema	DataStreamQueryOperation.getResolvedSchema() Deprecated.
ResolvedSchema	ValuesQueryOperation.getResolvedSchema()
ResolvedSchema	TableSourceQueryOperation.getResolvedSchema()
ResolvedSchema	QueryOperation.getResolvedSchema() Resolved schema of this operation.
ResolvedSchema	ProjectQueryOperation.getResolvedSchema()
ResolvedSchema	SortQueryOperation.getResolvedSchema()
ResolvedSchema	WindowAggregateQueryOperation.getResolvedSchema()
ResolvedSchema	SourceQueryOperation.getResolvedSchema()
ResolvedSchema	JoinQueryOperation.getResolvedSchema()
ResolvedSchema	CalculatedQueryOperation.getResolvedSchema()
ResolvedSchema	AggregateQueryOperation.getResolvedSchema()
ResolvedSchema	FilterQueryOperation.getResolvedSchema()
ResolvedSchema	DistinctQueryOperation.getResolvedSchema()
ResolvedSchema	SetQueryOperation.getResolvedSchema()

Constructors in org.apache.flink.table.operations with parameters of type ResolvedSchema

Constructor and Description
AggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, QueryOperation child, ResolvedSchema resolvedSchema)
CalculatedQueryOperation(ContextResolvedFunction resolvedFunction, List<ResolvedExpression> arguments, ResolvedSchema resolvedSchema)
DataStreamQueryOperation(DataStream<E> dataStream, int[] fieldIndices, ResolvedSchema resolvedSchema) Deprecated.
DataStreamQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, int[] fieldIndices, ResolvedSchema resolvedSchema) Deprecated.
ProjectQueryOperation(List<ResolvedExpression> projectList, QueryOperation child, ResolvedSchema resolvedSchema)
SetQueryOperation(QueryOperation leftOperation, QueryOperation rightOperation, SetQueryOperation.SetQueryOperationType type, boolean all, ResolvedSchema resolvedSchema)
ValuesQueryOperation(List<List<ResolvedExpression>> values, ResolvedSchema resolvedSchema)
WindowAggregateQueryOperation(List<ResolvedExpression> groupingExpressions, List<ResolvedExpression> aggregateExpressions, List<ResolvedExpression> windowPropertiesExpressions, WindowAggregateQueryOperation.ResolvedGroupWindow groupWindow, QueryOperation child, ResolvedSchema resolvedSchema)

Uses of ResolvedSchema in org.apache.flink.table.planner.connectors

Methods in org.apache.flink.table.planner.connectors with parameters of type ResolvedSchema

Modifier and Type	Method and Description
static RowType	DynamicSourceUtils.createProducedType(ResolvedSchema schema, DynamicTableSource source) Returns the DataType that a source should produce as the input into the runtime.
static List<Column.MetadataColumn>	DynamicSourceUtils.createRequiredMetadataColumns(ResolvedSchema schema, DynamicTableSource source) Returns a list of required metadata columns.
static List<Column.MetadataColumn>	DynamicSourceUtils.extractMetadataColumns(ResolvedSchema schema)
static boolean	DynamicSourceUtils.isSourceChangeEventsDuplicate(ResolvedSchema resolvedSchema, DynamicTableSource tableSource, TableConfig tableConfig) Returns true if the table source produces duplicate change events.
static boolean	DynamicSourceUtils.isUpsertSource(ResolvedSchema resolvedSchema, DynamicTableSource tableSource) Returns true if the table is an upsert source.
static org.apache.calcite.rel.RelNode	DynamicSinkUtils.validateSchemaAndApplyImplicitCast(org.apache.calcite.rel.RelNode query, ResolvedSchema sinkSchema, String tableDebugName, 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.

Uses of ResolvedSchema in org.apache.flink.table.planner.operations

Methods in org.apache.flink.table.planner.operations that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	InternalDataStreamQueryOperation.getResolvedSchema() Deprecated.
ResolvedSchema	PlannerQueryOperation.getResolvedSchema()

Constructors in org.apache.flink.table.planner.operations with parameters of type ResolvedSchema

Constructor and Description
InternalDataStreamQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, int[] fieldIndices, ResolvedSchema resolvedSchema, boolean[] fieldNullables, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic) Deprecated.

Uses of ResolvedSchema in org.apache.flink.table.types.utils

Methods in org.apache.flink.table.types.utils that return ResolvedSchema

Modifier and Type	Method and Description
static ResolvedSchema	DataTypeUtils.expandCompositeTypeToSchema(DataType dataType) Expands a composite DataType to a corresponding ResolvedSchema.

Uses of ResolvedSchema in org.apache.flink.table.typeutils

Methods in org.apache.flink.table.typeutils that return ResolvedSchema

Modifier and Type	Method and Description
ResolvedSchema	FieldInfoUtils.TypeInfoSchema.toResolvedSchema()

Uses of ResolvedSchema in org.apache.flink.table.utils.print

Methods in org.apache.flink.table.utils.print with parameters of type ResolvedSchema

Modifier and Type	Method and Description
static TableauStyle	PrintStyle.tableauWithDataInferredColumnWidths(ResolvedSchema schema, RowDataToStringConverter converter) Like PrintStyle.tableauWithDataInferredColumnWidths(ResolvedSchema, RowDataToStringConverter, int, boolean, boolean), but using default values.
static TableauStyle	PrintStyle.tableauWithDataInferredColumnWidths(ResolvedSchema schema, RowDataToStringConverter converter, int maxColumnWidth, boolean printNullAsEmpty, boolean printRowKind) Like PrintStyle.tableauWithTypeInferredColumnWidths(ResolvedSchema, RowDataToStringConverter, int, boolean, boolean), but uses the data to infer the column size.
static TableauStyle	PrintStyle.tableauWithTypeInferredColumnWidths(ResolvedSchema schema, RowDataToStringConverter converter, int maxColumnWidth, boolean printNullAsEmpty, boolean printRowKind) Create a new TableauStyle using column widths computed from the type.