org.apache.paimon.flink.action.cdc.pulsar

Class PulsarActionUtils

java.lang.Object

org.apache.paimon.flink.action.cdc.pulsar.PulsarActionUtils

public class PulsarActionUtils
extends Object

Utils for Pulsar synchronization.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.flink.configuration.ConfigOption<List<String>>	TOPIC
static org.apache.flink.configuration.ConfigOption<String>	TOPIC_PATTERN
static org.apache.flink.configuration.ConfigOption<String>	VALUE_FORMAT

Constructor Summary

Constructors

Constructor and Description
PulsarActionUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.connector.pulsar.source.PulsarSource<CdcSourceRecord>	buildPulsarSource(org.apache.flink.configuration.Configuration pulsarConfig, org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord> deserializationSchema)
static MessageQueueSchemaUtils.ConsumerWrapper	createPulsarConsumer(org.apache.flink.configuration.Configuration pulsarConfig, org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord> deserializationSchema) Referenced to PulsarPartitionSplitReader.createPulsarConsumer(org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition).
static String	findOneTopic(org.apache.flink.configuration.Configuration pulsarConfig)
static DataFormat	getDataFormat(org.apache.flink.configuration.Configuration pulsarConfig)

Methods inherited from class java.lang.Object

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

Field Detail

VALUE_FORMAT

public static final org.apache.flink.configuration.ConfigOption<String> VALUE_FORMAT

TOPIC

public static final org.apache.flink.configuration.ConfigOption<List<String>> TOPIC

TOPIC_PATTERN

public static final org.apache.flink.configuration.ConfigOption<String> TOPIC_PATTERN

Constructor Detail

PulsarActionUtils

public PulsarActionUtils()

Method Detail

buildPulsarSource

public static org.apache.flink.connector.pulsar.source.PulsarSource<CdcSourceRecord> buildPulsarSource(org.apache.flink.configuration.Configuration pulsarConfig,
                                                                                                       org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord> deserializationSchema)

getDataFormat

public static DataFormat getDataFormat(org.apache.flink.configuration.Configuration pulsarConfig)

createPulsarConsumer

public static MessageQueueSchemaUtils.ConsumerWrapper createPulsarConsumer(org.apache.flink.configuration.Configuration pulsarConfig,
                                                                           org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord> deserializationSchema)

Referenced to PulsarPartitionSplitReader.createPulsarConsumer(org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition).

findOneTopic

public static String findOneTopic(org.apache.flink.configuration.Configuration pulsarConfig)