Package io.delta.kernel.unitycatalog.metrics

Class UcPublishTelemetry.MetricsCollector

Object

io.delta.kernel.unitycatalog.metrics.UcPublishTelemetry.MetricsCollector

Enclosing class:

UcPublishTelemetry

public static class UcPublishTelemetry.MetricsCollector
extends Object

Mutable collector for gathering metrics during publish.

Field Summary

Fields

Modifier and Type	Field	Description
final io.delta.kernel.internal.metrics.Timer	totalPublishTimer

Constructor Summary

Constructors

Constructor	Description
MetricsCollector()

Method Summary

Modifier and Type	Method	Description
UcPublishTelemetry.MetricsResult	capture()
int	getCommitsAlreadyPublished()
int	getCommitsPublished()
void	incrementCommitsAlreadyPublished()	Increments the counter for commits already published by another process.
void	incrementCommitsPublished()

Methods inherited from class java.lang.Object

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

Field Details

totalPublishTimer

public final io.delta.kernel.internal.metrics.Timer totalPublishTimer

Constructor Details

MetricsCollector

public MetricsCollector()

Method Details

incrementCommitsPublished

public void incrementCommitsPublished()

incrementCommitsAlreadyPublished

public void incrementCommitsAlreadyPublished()

Increments the counter for commits already published by another process. Called when FileAlreadyExistsException indicates the commit was previously published.

getCommitsPublished

public int getCommitsPublished()

Returns:

number of commits published

getCommitsAlreadyPublished

public int getCommitsAlreadyPublished()

Returns:

number of commits already published by another process

capture

public UcPublishTelemetry.MetricsResult capture()