Uses of Class
org.apache.flink.table.api.Schema

Packages that use Schema

Package	Description
org.apache.flink.table.api
org.apache.flink.table.api.bridge.internal
org.apache.flink.table.api.bridge.java
org.apache.flink.table.api.bridge.java.internal
org.apache.flink.table.catalog
org.apache.flink.table.planner.delegation.hive

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

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

Modifier and Type	Method and Description
Schema	Schema.Builder.build() Returns an instance of an unresolved Schema.
static Schema	Schema.derived() Convenience method for stating explicitly that a schema is empty and should be fully derived by the framework.
Schema	TableSchema.toSchema() Deprecated. Helps to migrate to the new Schema class.

Methods in org.apache.flink.table.api that return types with arguments of type Schema

Modifier and Type	Method and Description
Optional<Schema>	TableDescriptor.getSchema()

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

Modifier and Type	Method and Description
Schema.Builder	Schema.Builder.fromSchema(Schema unresolvedSchema) Adopts all members from the given unresolved schema.
TableDescriptor.Builder	TableDescriptor.Builder.schema(Schema schema) Define the schema of the TableDescriptor.

Constructors in org.apache.flink.table.api with parameters of type Schema

Constructor and Description
TableDescriptor(Schema schema, Map<String,String> options, List<String> partitionKeys, String comment)

Uses of Schema in org.apache.flink.table.api.bridge.internal

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

Modifier and Type	Method and Description
protected <T> Table	AbstractStreamTableEnvironmentImpl.fromStreamInternal(DataStream<T> dataStream, Schema schema, String viewPath, ChangelogMode changelogMode)

Uses of Schema in org.apache.flink.table.api.bridge.java

Methods in org.apache.flink.table.api.bridge.java with parameters of type Schema

Modifier and Type	Method and Description
<T> void	StreamTableEnvironment.createTemporaryView(String path, DataStream<T> dataStream, Schema schema) Creates a view from the given DataStream in a given path.
Table	StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream, Schema schema) Converts the given DataStream of changelog entries into a Table.
Table	StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream, Schema schema, ChangelogMode changelogMode) Converts the given DataStream of changelog entries into a Table.
<T> Table	StreamTableEnvironment.fromDataStream(DataStream<T> dataStream, Schema schema) Converts the given DataStream into a Table.
DataStream<Row>	StreamTableEnvironment.toChangelogStream(Table table, Schema targetSchema) Converts the given Table into a DataStream of changelog entries.
DataStream<Row>	StreamTableEnvironment.toChangelogStream(Table table, Schema targetSchema, ChangelogMode changelogMode) Converts the given Table into a DataStream of changelog entries.

Uses of Schema in org.apache.flink.table.api.bridge.java.internal

Methods in org.apache.flink.table.api.bridge.java.internal with parameters of type Schema

Modifier and Type	Method and Description
<T> void	StreamTableEnvironmentImpl.createTemporaryView(String path, DataStream<T> dataStream, Schema schema)
Table	StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream, Schema schema)
Table	StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream, Schema schema, ChangelogMode changelogMode)
<T> Table	StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream, Schema schema)
DataStream<Row>	StreamTableEnvironmentImpl.toChangelogStream(Table table, Schema targetSchema)
DataStream<Row>	StreamTableEnvironmentImpl.toChangelogStream(Table table, Schema targetSchema, ChangelogMode changelogMode)

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

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

Modifier and Type	Method and Description
Schema	SchemaTranslator.ConsumingResult.getSchema()
Schema	SchemaTranslator.ProducingResult.getSchema()
Schema	ExternalCatalogTable.getUnresolvedSchema()
Schema	QueryOperationCatalogView.getUnresolvedSchema()
default Schema	CatalogBaseTable.getUnresolvedSchema() Returns the schema of the table or view.
Schema	ResolvedCatalogView.getUnresolvedSchema()
Schema	DefaultCatalogTable.getUnresolvedSchema()
Schema	ResolvedCatalogTable.getUnresolvedSchema()

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

Modifier and Type	Method and Description
static SchemaTranslator.ConsumingResult	SchemaTranslator.createConsumingResult(DataTypeFactory dataTypeFactory, DataType inputDataType, Schema declaredSchema, boolean mergePhysicalSchema) Converts the given DataType and an optional declared Schema (possibly incomplete) into the final SchemaTranslator.ConsumingResult.
static SchemaTranslator.ConsumingResult	SchemaTranslator.createConsumingResult(DataTypeFactory dataTypeFactory, TypeInformation<?> inputTypeInfo, Schema declaredSchema) Converts the given TypeInformation and an optional declared Schema (possibly incomplete) into the final SchemaTranslator.ConsumingResult.
static SchemaTranslator.ProducingResult	SchemaTranslator.createProducingResult(ResolvedSchema inputSchema, Schema declaredSchema) Converts the given DataType into the final SchemaTranslator.ProducingResult.
static CatalogTable	CatalogTable.of(Schema schema, String comment, List<String> partitionKeys, Map<String,String> options) Creates a basic implementation of this interface.
static CatalogView	CatalogView.of(Schema schema, String comment, String originalQuery, String expandedQuery, Map<String,String> options) Creates a basic implementation of this interface.
ResolvedSchema	SchemaResolver.resolve(Schema schema)

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

Constructor and Description
DefaultCatalogTable(Schema schema, String comment, List<String> partitionKeys, Map<String,String> options)
ExternalCatalogTable(Schema schema)

Uses of Schema in org.apache.flink.table.planner.delegation.hive

Methods in org.apache.flink.table.planner.delegation.hive with parameters of type Schema

Modifier and Type	Method and Description
static TableSchema	HiveParserUtils.fromUnresolvedSchema(Schema schema) Helps to migrate the new Schema to old API methods.