org.apache.paimon.flink.action.cdc

Class SyncJobHandler

java.lang.Object

org.apache.paimon.flink.action.cdc.SyncJobHandler

public class SyncJobHandler
extends Object

Provide different function according to CDC source type.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SyncJobHandler.SourceType CDC source type.

Constructor Summary

Constructors

Constructor and Description
SyncJobHandler(SyncJobHandler.SourceType sourceType, Map<String,String> cdcSourceConfig, String database)
SyncJobHandler(SyncJobHandler.SourceType sourceType, Map<String,String> cdcSourceConfig, String database, String table)

Method Summary

Modifier and Type	Method and Description
void	checkRequiredOption()
MessageQueueSchemaUtils.ConsumerWrapper	provideConsumer()
DataFormat	provideDataFormat()
String	provideDefaultJobName()
CdcMetadataConverter	provideMetadataConverter(String column)
org.apache.flink.api.common.functions.FlatMapFunction<CdcSourceRecord,RichCdcMultiplexRecord>	provideRecordParser(List<ComputedColumn> computedColumns, TypeMapping typeMapping, CdcMetadataConverter[] metadataConverters)
org.apache.flink.api.connector.source.Source<CdcSourceRecord,?,?>	provideSource()
String	provideSourceName()
void	registerJdbcDriver()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SyncJobHandler

public SyncJobHandler(SyncJobHandler.SourceType sourceType,
                      Map<String,String> cdcSourceConfig,
                      String database)

SyncJobHandler

public SyncJobHandler(SyncJobHandler.SourceType sourceType,
                      Map<String,String> cdcSourceConfig,
                      String database,
                      String table)

Method Detail

provideSourceName

public String provideSourceName()

provideDefaultJobName

public String provideDefaultJobName()

registerJdbcDriver

public void registerJdbcDriver()

checkRequiredOption

public void checkRequiredOption()

provideSource

public org.apache.flink.api.connector.source.Source<CdcSourceRecord,?,?> provideSource()

provideRecordParser

public org.apache.flink.api.common.functions.FlatMapFunction<CdcSourceRecord,RichCdcMultiplexRecord> provideRecordParser(List<ComputedColumn> computedColumns,
                                                                                                                         TypeMapping typeMapping,
                                                                                                                         CdcMetadataConverter[] metadataConverters)

provideDataFormat

public DataFormat provideDataFormat()

provideConsumer

public MessageQueueSchemaUtils.ConsumerWrapper provideConsumer()

provideMetadataConverter

public CdcMetadataConverter provideMetadataConverter(String column)