Uses of Interface
org.apache.paimon.flink.log.LogSourceProvider

Packages that use LogSourceProvider

Package	Description
org.apache.paimon.flink.kafka
org.apache.paimon.flink.log
org.apache.paimon.flink.source

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

Classes in org.apache.paimon.flink.kafka that implement LogSourceProvider

Modifier and Type	Class and Description
class	KafkaLogSourceProvider A Kafka LogSourceProvider.

Uses of LogSourceProvider in org.apache.paimon.flink.log

Methods in org.apache.paimon.flink.log that return LogSourceProvider

Modifier and Type	Method and Description
LogSourceProvider	LogStoreTableFactory.createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext, int[][] projectFields) Creates a LogSourceProvider instance from a CatalogTable and additional context information.

Uses of LogSourceProvider in org.apache.paimon.flink.source

Constructors in org.apache.paimon.flink.source with parameters of type LogSourceProvider

Constructor and Description
LogHybridSourceFactory(LogSourceProvider provider)