org.apache.paimon.flink.source.metrics

Class FileStoreSourceReaderMetrics

java.lang.Object

org.apache.paimon.flink.source.metrics.FileStoreSourceReaderMetrics

public class FileStoreSourceReaderMetrics
extends Object

Source reader metrics.

Field Summary

Fields

Modifier and Type	Field and Description
static long	UNDEFINED

Constructor Summary

Constructors

Constructor and Description
FileStoreSourceReaderMetrics(org.apache.flink.metrics.MetricGroup sourceReaderMetricGroup)

Method Summary

Modifier and Type	Method and Description
long	getLatestFileCreationTime()
void	recordSnapshotUpdate(long fileCreationTime) Called when consumed snapshot changes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

UNDEFINED

public static final long UNDEFINED

See Also:

Constant Field Values

Constructor Detail

FileStoreSourceReaderMetrics

public FileStoreSourceReaderMetrics(org.apache.flink.metrics.MetricGroup sourceReaderMetricGroup)

Method Detail

recordSnapshotUpdate

public void recordSnapshotUpdate(long fileCreationTime)

Called when consumed snapshot changes.

getLatestFileCreationTime

public long getLatestFileCreationTime()