序列化表格

程序包 org.apache.flink.cdc.connectors.oceanbase.catalog

类org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

connectionProvider

com.oceanbase.connector.flink.connection.OceanBaseConnectionProvider connectionProvider

connectorOptions

com.oceanbase.connector.flink.OceanBaseConnectorOptions connectorOptions

类org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogException扩展RuntimeException实现可序列化

类org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

columnName

String columnName

The name of the column.

ordinalPosition

int ordinalPosition

The position of the column within the table (starting at 0).

dataType

String dataType

The column data type.

isNullable

boolean isNullable

The column nullability.

defaultValue

String defaultValue

The default value for the column.

columnSize

Integer columnSize

The column size. For numeric data, this is the maximum precision. For character data, this is the length in characters. For other data types, this is null.

numericScale

Integer numericScale

The number of fractional digits for numeric data. This is null for other data types. NUMBER_SCALE in information_schema.COLUMNS.

columnComment

String columnComment

The column comment. COLUMN_COMMENT in information_schema.COLUMNS.

类org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog扩展OceanBaseCatalog实现可序列化

类org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog扩展OceanBaseCatalog实现可序列化

程序包 org.apache.flink.cdc.connectors.oceanbase.sink

类org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink扩展Object实现可序列化

序列化字段

connectorOptions

com.oceanbase.connector.flink.OceanBaseConnectorOptions connectorOptions

zoneId

java.time.ZoneId zoneId

类org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema扩展Object实现可序列化

序列化字段

cache

org.apache.flink.shaded.guava31.com.google.common.cache.Cache<K,V> cache

schemaMaps

Map<K,V> schemaMaps

pipelineZoneId

java.time.ZoneId pipelineZoneId

ZoneId from pipeline config to support timestamp with local time zone.

类org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseMetadataApplier扩展Object实现可序列化

序列化字段

catalog

OceanBaseCatalog catalog

类org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseRowConvert扩展Object实现可序列化

serialVersionUID:

1L