Uses of Class
org.apache.paimon.flink.source.metrics.FileStoreSourceReaderMetrics

Packages that use FileStoreSourceReaderMetrics

Package	Description
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align

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

Methods in org.apache.paimon.flink.source with parameters of type FileStoreSourceReaderMetrics

Modifier and Type	Method and Description
static void	FlinkRecordsWithSplitIds.emitRecord(org.apache.flink.api.connector.source.SourceReaderContext context, org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> element, org.apache.flink.api.connector.source.SourceOutput<org.apache.flink.table.data.RowData> output, FileStoreSourceSplitState state, FileStoreSourceReaderMetrics metrics)

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

Constructor and Description
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit)
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue)
FileStoreSourceSplitReader(TableRead tableRead, RecordLimiter limiter, FileStoreSourceReaderMetrics metrics)

Uses of FileStoreSourceReaderMetrics in org.apache.paimon.flink.source.align

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

Constructor and Description

AlignedSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue)