Package org.apache.flink.runtime.checkpoint

Class SubTaskInitializationMetricsBuilder

java.lang.Object

org.apache.flink.runtime.checkpoint.SubTaskInitializationMetricsBuilder

@NotThreadSafe
public class SubTaskInitializationMetricsBuilder
extends Object

A builder for SubTaskInitializationMetrics.

Constructor Summary

Constructors

Constructor	Description
SubTaskInitializationMetricsBuilder(long initializationStartTs)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

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

Constructor Detail

SubTaskInitializationMetricsBuilder

public SubTaskInitializationMetricsBuilder(long initializationStartTs)

Method Detail

getInitializationStartTs

public long getInitializationStartTs()

addDurationMetric

public SubTaskInitializationMetricsBuilder addDurationMetric(String name,
                                                             long value)

This adds a custom "duration" type metric, handled and aggregated by the JobInitializationMetricsBuilder. If a metric with the given name already exists the old and the new values will be added together.

setStatus

public SubTaskInitializationMetricsBuilder setStatus(InitializationStatus status)

build

public SubTaskInitializationMetrics build()

build

@VisibleForTesting
public SubTaskInitializationMetrics build(long endTs)