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

Class Summary

Class	Description
PulsarActionUtils	Utils for Pulsar synchronization.
PulsarDebeziumAvroDeserializationSchema	A simple deserialization schema for CdcSourceRecord.
PulsarSyncDatabaseAction	Synchronize database from Pulsar.
PulsarSyncDatabaseActionFactory	Factory to create PulsarSyncDatabaseAction.
PulsarSyncTableAction	Synchronize table from Pulsar.
PulsarSyncTableActionFactory	Factory to create PulsarSyncTableAction.