public class TaskStateStats extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
TaskStateStats.TaskStateStatsSummary
Summary of the subtask stats of a single task/operator.
|
Modifier and Type | Method and Description |
---|---|
long |
getCheckpointedSize() |
long |
getEndToEndDuration(long triggerTimestamp)
Returns the duration of this checkpoint at the task/operator calculated as the time since
triggering until the latest acknowledged subtask or
-1 if no subtask was
acknowledged yet. |
JobVertexID |
getJobVertexId() |
SubtaskStateStats |
getLatestAcknowledgedSubtaskStats() |
long |
getLatestAckTimestamp() |
int |
getNumberOfAcknowledgedSubtasks() |
int |
getNumberOfSubtasks() |
long |
getPersistedDataStats() |
long |
getProcessedDataStats() |
long |
getStateSize() |
SubtaskStateStats[] |
getSubtaskStats()
Returns the stats for all subtasks.
|
TaskStateStats.TaskStateStatsSummary |
getSummaryStats() |
public JobVertexID getJobVertexId()
public int getNumberOfSubtasks()
public int getNumberOfAcknowledgedSubtasks()
@Nullable public SubtaskStateStats getLatestAcknowledgedSubtaskStats()
null
if none was acknowledged
yet.public long getLatestAckTimestamp()
-1
if none was
acknowledged yet..public long getCheckpointedSize()
public long getStateSize()
public long getProcessedDataStats()
public long getPersistedDataStats()
public long getEndToEndDuration(long triggerTimestamp)
-1
if no subtask was
acknowledged yet.-1
if no subtask was
acknowledged yet.public SubtaskStateStats[] getSubtaskStats()
Elements of the returned array are null
if no stats are available yet for the
respective subtask.
Note: The returned array must not be modified.
null
if no stats available yet).public TaskStateStats.TaskStateStatsSummary getSummaryStats()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.