@NotThreadSafe public class SubTaskInitializationMetricsBuilder extends Object
SubTaskInitializationMetrics
.Constructor and Description |
---|
SubTaskInitializationMetricsBuilder(long initializationStartTs) |
Modifier and Type | Method and Description |
---|---|
SubTaskInitializationMetricsBuilder |
addDurationMetric(String name,
long value)
This adds a custom "duration" type metric, handled and aggregated by the
JobInitializationMetricsBuilder . |
SubTaskInitializationMetrics |
build() |
SubTaskInitializationMetrics |
build(long endTs) |
long |
getInitializationStartTs() |
SubTaskInitializationMetricsBuilder |
setStatus(InitializationStatus status) |
public SubTaskInitializationMetricsBuilder(long initializationStartTs)
public long getInitializationStartTs()
public SubTaskInitializationMetricsBuilder addDurationMetric(String name, long value)
JobInitializationMetricsBuilder
. If a metric with the given name already exists the old and
the new values will be added together.public SubTaskInitializationMetricsBuilder setStatus(InitializationStatus status)
public SubTaskInitializationMetrics build()
@VisibleForTesting public SubTaskInitializationMetrics build(long endTs)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.