Collection<ArchivedJson> |
JobConfigHandler.JobConfigJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtaskExecutionAttemptAccumulatorsHandler.SubtaskExecutionAttemptAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtaskExecutionAttemptDetailsHandler.SubtaskExecutionAttemptDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobPlanHandler.JobPlanJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobVertexAccumulatorsHandler.JobVertexAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobVertexTaskManagersHandler.JobVertexTaskManagersJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobExceptionsHandler.JobExceptionsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtasksTimesHandler.SubtasksTimesJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobVertexDetailsHandler.JobVertexDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobAccumulatorsHandler.JobAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
JobDetailsHandler.JobDetailsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
CurrentJobsOverviewHandler.CurrentJobsOverviewJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
Collection<ArchivedJson> |
SubtasksAllAccumulatorsHandler.SubtasksAllAccumulatorsJsonArchivist.archiveJsonWithPath(AccessExecutionGraph graph) |
static String |
JobAccumulatorsHandler.createJobAccumulatorsJson(AccessExecutionGraph graph) |
static String |
JobConfigHandler.createJobConfigJson(AccessExecutionGraph graph) |
static String |
JobDetailsHandler.createJobDetailsJson(AccessExecutionGraph graph,
MetricFetcher fetcher) |
static String |
JobExceptionsHandler.createJobExceptionsJson(AccessExecutionGraph graph) |
CompletableFuture<String> |
JobConfigHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
CompletableFuture<String> |
AbstractJobVertexRequestHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
CompletableFuture<String> |
JobPlanHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
abstract CompletableFuture<String> |
AbstractExecutionGraphRequestHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
CompletableFuture<String> |
JobExceptionsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
CompletableFuture<String> |
JobAccumulatorsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |
CompletableFuture<String> |
JobDetailsHandler.handleRequest(AccessExecutionGraph graph,
Map<String,String> params) |