Uses of Interface
org.apache.paimon.flink.action.cdc.MessageQueueSchemaUtils.ConsumerWrapper

Packages that use MessageQueueSchemaUtils.ConsumerWrapper

Package	Description
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.kafka
org.apache.paimon.flink.action.cdc.pulsar

Uses of MessageQueueSchemaUtils.ConsumerWrapper in org.apache.paimon.flink.action.cdc

Methods in org.apache.paimon.flink.action.cdc that return MessageQueueSchemaUtils.ConsumerWrapper

Modifier and Type	Method and Description
MessageQueueSchemaUtils.ConsumerWrapper	SyncJobHandler.provideConsumer()

Methods in org.apache.paimon.flink.action.cdc with parameters of type MessageQueueSchemaUtils.ConsumerWrapper

Modifier and Type	Method and Description
static Schema	MessageQueueSchemaUtils.getSchema(MessageQueueSchemaUtils.ConsumerWrapper consumer, DataFormat dataFormat, TypeMapping typeMapping) Retrieves the Kafka schema for a given topic.

Uses of MessageQueueSchemaUtils.ConsumerWrapper in org.apache.paimon.flink.action.cdc.kafka

Methods in org.apache.paimon.flink.action.cdc.kafka that return MessageQueueSchemaUtils.ConsumerWrapper

Modifier and Type	Method and Description
static MessageQueueSchemaUtils.ConsumerWrapper	KafkaActionUtils.getKafkaEarliestConsumer(org.apache.flink.configuration.Configuration kafkaConfig, org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> deserializationSchema)

Uses of MessageQueueSchemaUtils.ConsumerWrapper in org.apache.paimon.flink.action.cdc.pulsar

Methods in org.apache.paimon.flink.action.cdc.pulsar that return MessageQueueSchemaUtils.ConsumerWrapper

Modifier and Type	Method and Description
static MessageQueueSchemaUtils.ConsumerWrapper	PulsarActionUtils.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).