Package io.github.flink.gcp.connector.base.metrics

Class MetricValues

java.lang.Object

io.github.flink.gcp.connector.base.metrics.MetricValues

@Internal
public final class MetricValues
extends Object

Shared boundary handling for connector metric values.

Method Summary

Modifier and Type	Method	Description
static long	elapsedMillis(long now, long earlier)	Returns elapsed milliseconds, clamped for future values and saturated on overflow.

Methods inherited from class java.lang.Object

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

Method Details

elapsedMillis

public static long elapsedMillis(long now,
 long earlier)

Returns elapsed milliseconds, clamped for future values and saturated on overflow.