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

类概要

类	说明
OceanBaseDataSink	A DataSink for "OceanBase" pipeline connector.
OceanBaseDataSinkOptions	Options for OceanBaseDataSink.
OceanBaseEventSerializationSchema	A serializer for Event to Record.
OceanBaseMetadataApplier	Supports OceanBaseDataSink to schema evolution.
OceanBaseRowConvert	converter RecordData type object to oceanbase field.
OceanBaseUtils	Utilities for conversion from source table to OceanBase table.
OceanBaseUtils.CdcDataTypeTransformer	Transforms CDC DataType to OceanBase data type.