类的使用
org.apache.flink.cdc.common.schema.Schema.Builder

使用Schema.Builder的程序包

程序包	说明
org.apache.flink.cdc.common.schema

org.apache.flink.cdc.common.schema中Schema.Builder的使用

返回Schema.Builder的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
Schema.Builder	Schema.Builder.column(Column column)
Schema.Builder	Schema.Builder.comment(String comment) Declares table comment.
Schema.Builder	Schema.Builder.fromRowDataType(DataType type) Adopts all fields of the given row as physical columns of the schema.
Schema.Builder	Schema.Builder.metadataColumn(String columnName, DataType type) Declares a metadata column that is appended to this schema.
Schema.Builder	Schema.Builder.metadataColumn(String columnName, DataType type, String metadataKey) Declares a metadata column that is appended to this schema.
Schema.Builder	Schema.Builder.metadataColumn(String columnName, DataType type, String metadataKey, String comment) Declares a metadata column that is appended to this schema.
static Schema.Builder	Schema.newBuilder() Builder for configuring and creating instances of Schema.
Schema.Builder	Schema.Builder.option(String key, String value) Declares an option.
Schema.Builder	Schema.Builder.options(Map<String,String> options) Declares options.
Schema.Builder	Schema.Builder.partitionKey(List<String> columnNames) Declares a partition key constraint for a set of given columns.
Schema.Builder	Schema.Builder.partitionKey(String... columnNames) Declares a partition key constraint for a set of given columns.
Schema.Builder	Schema.Builder.physicalColumn(String columnName, DataType type) Declares a physical column that is appended to this schema.
Schema.Builder	Schema.Builder.physicalColumn(String columnName, DataType type, String comment) Declares a physical column that is appended to this schema.
Schema.Builder	Schema.Builder.physicalColumn(String columnName, DataType type, String comment, String defaultValue) Declares a physical column that is appended to this schema.
Schema.Builder	Schema.Builder.primaryKey(List<String> columnNames) Declares a primary key constraint for a set of given columns.
Schema.Builder	Schema.Builder.primaryKey(String... columnNames) Declares a primary key constraint for a set of given columns.
Schema.Builder	Schema.Builder.setColumns(List<Column> columns) Set new columns.