T
- Type of statistics to trackpublic interface JobVertexStatsTracker<T extends Statistics>
AccessExecutionJobVertex
.Modifier and Type | Method and Description |
---|---|
Optional<T> |
getVertexStats(JobID jobId,
AccessExecutionJobVertex vertex)
Returns statistics for a job vertex.
|
void |
shutDown()
Shuts the
JobVertexStatsTracker down. |
Optional<T> getVertexStats(JobID jobId, AccessExecutionJobVertex vertex)
jobId
- job the vertex belongs tovertex
- Vertex to get the stats for.void shutDown() throws FlinkException
JobVertexStatsTracker
down.FlinkException
- if the JobVertexStatsTracker
could not be shut downCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.