org.apache.flink.cdc.common.schema

类 Schema.Builder

java.lang.Object

org.apache.flink.cdc.common.schema.Schema.Builder

封闭类:

Schema

@PublicEvolving
public static final class Schema.Builder
extends Object

A builder for constructing an immutable but still unresolved Schema.

构造器概要

构造器

构造器和说明
Builder()

方法概要

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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

Builder

public Builder()

方法详细资料

partitionKey

public Schema.Builder partitionKey(String... columnNames)

Declares a partition key constraint for a set of given columns. Partition key uniquely identify a row in a table. Neither of columns in a partition can be nullable.

参数:

columnNames - columns that form a unique primary key

partitionKey

public Schema.Builder partitionKey(List<String> columnNames)

Declares a partition key constraint for a set of given columns. Partition key uniquely identify a row in a table. Neither of columns in a partition can be nullable.

参数:

columnNames - columns that form a unique primary key

fromRowDataType

public Schema.Builder fromRowDataType(DataType type)

Adopts all fields of the given row as physical columns of the schema.

physicalColumn

public Schema.Builder physicalColumn(String columnName,
                                     DataType type)

Declares a physical column that is appended to this schema.

参数:

columnName - column name

type - data type of the column

physicalColumn

public Schema.Builder physicalColumn(String columnName,
                                     DataType type,
                                     String comment)

Declares a physical column that is appended to this schema.

参数:

columnName - column name

type - data type of the column

comment - description of the column

physicalColumn

public Schema.Builder physicalColumn(String columnName,
                                     DataType type,
                                     String comment,
                                     String defaultValue)

Declares a physical column that is appended to this schema.

参数:

columnName - column name

type - data type of the column

comment - description of the column

defaultValue - default value of the column

metadataColumn

public Schema.Builder metadataColumn(String columnName,
                                     DataType type)

Declares a metadata column that is appended to this schema.

参数:

columnName - column name

type - data type of the column

metadataColumn

public Schema.Builder metadataColumn(String columnName,
                                     DataType type,
                                     String metadataKey)

Declares a metadata column that is appended to this schema.

参数:

columnName - column name

type - data type of the column

metadataKey - the key of metadata

metadataColumn

public Schema.Builder metadataColumn(String columnName,
                                     DataType type,
                                     String metadataKey,
                                     String comment)

Declares a metadata column that is appended to this schema.

参数:

columnName - column name

type - data type of the column

metadataKey - the key of metadata

comment - description of the column

column

public Schema.Builder column(Column column)

primaryKey

public Schema.Builder primaryKey(String... columnNames)

Declares a primary key constraint for a set of given columns. Primary key uniquely identify a row in a table. Neither of columns in a primary can be nullable.

参数:

columnNames - columns that form a unique primary key

primaryKey

public Schema.Builder primaryKey(List<String> columnNames)

Declares a primary key constraint for a set of given columns. Primary key uniquely identify a row in a table. Neither of columns in a primary can be nullable.

参数:

columnNames - columns that form a unique primary key

options

public Schema.Builder options(Map<String,String> options)

Declares options.

option

public Schema.Builder option(String key,
                             String value)

Declares an option.

comment

public Schema.Builder comment(String comment)

Declares table comment.

setColumns

public Schema.Builder setColumns(List<Column> columns)

Set new columns.

build

public Schema build()

Returns an instance of a Schema.