Package org.apache.flink.runtime.rest.handler.legacy.metrics

Class MetricStore.JobMetricStoreSnapshot

java.lang.Object

org.apache.flink.runtime.rest.handler.legacy.metrics.MetricStore.JobMetricStoreSnapshot

Enclosing class:

MetricStore

@ThreadSafe
public static class MetricStore.JobMetricStoreSnapshot
extends Object

Sub-structure containing a snapshot of all jobs in the metric store.

Method Summary

Modifier and Type	Method	Description
MetricStore.ComponentMetricStore	getSubtaskAttemptMetricStore(String jobID, String taskID, int subtaskIndex, int attemptNumber)
MetricStore.ComponentMetricStore	getSubtaskMetricStore(String jobID, String taskID, int subtaskIndex)	Returns the MetricStore.ComponentMetricStore for the given job/task ID and subtask index.
Collection<? extends MetricStore.ComponentMetricStore>	values()

Methods inherited from class java.lang.Object

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

Method Detail

getSubtaskMetricStore

public MetricStore.ComponentMetricStore getSubtaskMetricStore(String jobID,
                                                              String taskID,
                                                              int subtaskIndex)

Returns the MetricStore.ComponentMetricStore for the given job/task ID and subtask index.

Parameters:

jobID - job ID

taskID - task ID

subtaskIndex - subtask index

Returns:

SubtaskMetricStore for the given IDs and index, or null if no store for the given arguments exists

getSubtaskAttemptMetricStore

public MetricStore.ComponentMetricStore getSubtaskAttemptMetricStore(String jobID,
                                                                     String taskID,
                                                                     int subtaskIndex,
                                                                     int attemptNumber)

values

public Collection<? extends MetricStore.ComponentMetricStore> values()