Hierarchy For Package org.apache.paimon.flink.sink.cdc

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
    • org.apache.flink.streaming.api.functions.ProcessFunction<I,O>
      • org.apache.paimon.flink.sink.cdc.CdcDynamicTableParsingProcessFunction<T>
      • org.apache.paimon.flink.sink.cdc.CdcMultiTableParsingProcessFunction<T>
      • org.apache.paimon.flink.sink.cdc.CdcParsingProcessFunction<T>
      • org.apache.paimon.flink.sink.cdc.UpdatedDataFieldsProcessFunctionBase<I,O>
        • org.apache.paimon.flink.sink.cdc.MultiTableUpdatedDataFieldsProcessFunction
        • org.apache.paimon.flink.sink.cdc.UpdatedDataFieldsProcessFunction
  • org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> (implements org.apache.flink.streaming.api.operators.KeyContextHandler, java.io.Serializable, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator, org.apache.flink.streaming.api.operators.YieldingOperator<OUT>)
    • org.apache.paimon.flink.sink.PrepareCommitOperator<IN,OUT> (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
      • org.apache.paimon.flink.sink.cdc.CdcRecordStoreMultiWriteOperator
      • org.apache.paimon.flink.sink.TableWriteOperator<IN>
        • org.apache.paimon.flink.sink.cdc.CdcDynamicBucketWriteOperator
        • org.apache.paimon.flink.sink.cdc.CdcRecordStoreWriteOperator
          • org.apache.paimon.flink.sink.cdc.CdcUnawareBucketWriteOperator
  • org.apache.paimon.flink.sink.cdc.CaseSensitiveUtils
  • org.apache.paimon.flink.sink.cdc.CdcFixedBucketChannelComputerBase<T> (implements org.apache.paimon.table.sink.ChannelComputer<T>)
    • org.apache.paimon.flink.sink.cdc.CdcRecordChannelComputer
  • org.apache.paimon.flink.sink.cdc.CdcMultiplexRecord (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.cdc.CdcMultiplexRecordChannelComputer (implements org.apache.paimon.table.sink.ChannelComputer<T>)
  • org.apache.paimon.flink.sink.cdc.CdcRecord (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.cdc.CdcRecordKeyAndBucketExtractor (implements org.apache.paimon.table.sink.KeyAndBucketExtractor<T>)
  • org.apache.paimon.flink.sink.cdc.CdcRecordPartitionKeyExtractor (implements org.apache.paimon.table.sink.PartitionKeyExtractor<T>)
  • org.apache.paimon.flink.sink.cdc.CdcRecordUtils
  • org.apache.paimon.flink.sink.cdc.CdcSinkBuilder<T>
  • org.apache.paimon.flink.sink.cdc.FlinkCdcMultiTableSink (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.cdc.FlinkCdcSyncDatabaseSinkBuilder<T>
  • org.apache.paimon.flink.sink.FlinkSink<T> (implements java.io.Serializable)
    • org.apache.paimon.flink.sink.FlinkWriteSink<T>
      • org.apache.paimon.flink.sink.cdc.CdcFixedBucketSink
      • org.apache.paimon.flink.sink.cdc.CdcUnawareBucketSink
      • org.apache.paimon.flink.sink.DynamicBucketSink<T>
        • org.apache.paimon.flink.sink.cdc.CdcDynamicBucketSinkBase<T>
          • org.apache.paimon.flink.sink.cdc.CdcDynamicBucketSink
  • org.apache.paimon.flink.sink.cdc.NewTableSchemaBuilder (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.cdc.RichCdcMultiplexRecord (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.cdc.RichCdcMultiplexRecordEventParser (implements org.apache.paimon.flink.sink.cdc.EventParser<T>)
  • org.apache.paimon.flink.sink.cdc.RichCdcRecord (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.cdc.RichCdcRecord.Builder
  • org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder
  • org.apache.paimon.flink.sink.cdc.RichEventParser (implements org.apache.paimon.flink.sink.cdc.EventParser<T>)

Interface Hierarchy

• org.apache.paimon.flink.sink.cdc.EventParser<T>
• java.io.Serializable
  • org.apache.paimon.flink.sink.cdc.EventParser.Factory<T>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.paimon.flink.sink.cdc.UpdatedDataFieldsProcessFunctionBase.ConvertAction