Interface | Description |
---|---|
JobVertexStatsTracker<T extends Statistics> |
Interface for a tracker of statistics for
AccessExecutionJobVertex . |
Statistics |
Represents one or more statistics samples.
|
Class | Description |
---|---|
TaskStatsRequestCoordinator<T,V> |
Encapsulates the common functionality for requesting statistics from individual tasks and
combining their responses.
|
TaskStatsRequestCoordinator.PendingStatsRequest<T,V> |
A pending task stats request, which collects samples from individual tasks and completes the
response future upon gathering all of of them.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.