序列化表格

程序包 com.oceanbase.connector.flink.sink

类com.oceanbase.connector.flink.sink.OceanBaseRecordFlusher扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

connectionProvider

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

dialect

com.oceanbase.connector.flink.dialect.OceanBaseDialect dialect

directLoadCache

com.oceanbase.connector.flink.utils.TableCache<com.alipay.oceanbase.rpc.table.ObTableDirectLoad> directLoadCache

lastCheckMemStoreTime

long lastCheckMemStoreTime

options

com.oceanbase.connector.flink.OceanBaseConnectorOptions options

tablePartInfoCache

com.oceanbase.connector.flink.utils.TableCache<com.oceanbase.connector.flink.connection.OceanBaseTablePartInfo> tablePartInfoCache

类com.oceanbase.connector.flink.sink.OceanBaseSink扩展Object实现可序列化

serialVersionUID:

1L

序列化字段

keyExtractor

com.oceanbase.connector.flink.table.DataChangeRecord.KeyExtractor keyExtractor

options

com.oceanbase.connector.flink.ConnectorOptions options

recordFlusher

com.oceanbase.connector.flink.sink.RecordFlusher recordFlusher

recordSerializer

com.oceanbase.connector.flink.table.RecordSerializationSchema<T> recordSerializer

typeSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer

writerEventListener

com.oceanbase.connector.flink.sink.OceanBaseWriterEvent.Listener writerEventListener

程序包 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

序列化字段

columnComment

String columnComment

The column comment. COLUMN_COMMENT in information_schema.COLUMNS.

columnName

String columnName

The name of 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.

dataType

String dataType

The column data type.

defaultValue

String defaultValue

The default value for the column.

isNullable

boolean isNullable

The column nullability.

numericScale

Integer numericScale

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

ordinalPosition

int ordinalPosition

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

类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<org.apache.flink.cdc.common.schema.Schema,List<org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseRowConvert.SerializationConverter>> cache

pipelineZoneId

java.time.ZoneId pipelineZoneId

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

schemaMaps

Map<org.apache.flink.cdc.common.event.TableId,org.apache.flink.cdc.common.schema.Schema> schemaMaps

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

序列化字段

catalog

OceanBaseCatalog catalog

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

serialVersionUID:

1L