org.apache.flink.cdc.connectors.oceanbase.catalog

类 OceanBaseTable.Builder

java.lang.Object

org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

封闭类:

OceanBaseTable

public static class OceanBaseTable.Builder
extends Object

Build a OceanBaseTable.

构造器概要

构造器

构造器和说明
Builder()

方法概要

限定符和类型	方法和说明
OceanBaseTable	build()
OceanBaseTable.Builder	setColumns(List<OceanBaseColumn> columns)
OceanBaseTable.Builder	setComment(String comment)
OceanBaseTable.Builder	setDatabaseName(String databaseName)
OceanBaseTable.Builder	setPartitionKeys(List<String> partitionKeys)
OceanBaseTable.Builder	setTableKeys(List<String> tableKeys)
OceanBaseTable.Builder	setTableName(String tableName)
OceanBaseTable.Builder	setTableProperties(Map<String,String> properties)
OceanBaseTable.Builder	setTableType(OceanBaseTable.TableType tableType)

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

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

构造器详细资料

Builder

public Builder()

方法详细资料

setDatabaseName

public OceanBaseTable.Builder setDatabaseName(String databaseName)

setTableName

public OceanBaseTable.Builder setTableName(String tableName)

setTableType

public OceanBaseTable.Builder setTableType(OceanBaseTable.TableType tableType)

setColumns

public OceanBaseTable.Builder setColumns(List<OceanBaseColumn> columns)

setTableKeys

public OceanBaseTable.Builder setTableKeys(List<String> tableKeys)

setPartitionKeys

public OceanBaseTable.Builder setPartitionKeys(List<String> partitionKeys)

setComment

public OceanBaseTable.Builder setComment(String comment)

setTableProperties

public OceanBaseTable.Builder setTableProperties(Map<String,String> properties)

build

public OceanBaseTable build()