Uses of Class
org.apache.paimon.flink.action.cdc.SyncTableActionBase.SchemaRetrievalException

Packages that use SyncTableActionBase.SchemaRetrievalException

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

Uses of SyncTableActionBase.SchemaRetrievalException in org.apache.paimon.flink.action.cdc

Methods in org.apache.paimon.flink.action.cdc that throw SyncTableActionBase.SchemaRetrievalException

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.