Uses of Class
org.apache.paimon.flink.kafka.KafkaLogSourceProvider

Packages that use KafkaLogSourceProvider

Package	Description
org.apache.paimon.flink.kafka

Uses of KafkaLogSourceProvider in org.apache.paimon.flink.kafka

Methods in org.apache.paimon.flink.kafka that return KafkaLogSourceProvider

Modifier and Type	Method and Description
KafkaLogSourceProvider	KafkaLogStoreFactory.createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext, int[][] projectFields)