程序包org.apache.flink.cdc.connectors.oceanbase.sink的分层结构

程序包分层结构:

• 所有程序包

类分层结构

• java.lang.Object
  • org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<R> (implements org.apache.flink.cdc.common.types.DataTypeVisitor<R>)
    • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer
  • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink (implements org.apache.flink.cdc.common.sink.DataSink, java.io.Serializable)
  • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions
  • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema (implements com.oceanbase.connector.flink.table.RecordSerializationSchema<T>)
  • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseMetadataApplier (implements org.apache.flink.cdc.common.sink.MetadataApplier)
  • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseRowConvert (implements java.io.Serializable)
  • org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils