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

Class JobExceptionsHandler.JobExceptionsJsonArchivist

java.lang.Object

org.apache.flink.runtime.rest.handler.legacy.JobExceptionsHandler.JobExceptionsJsonArchivist

All Implemented Interfaces:

JsonArchivist

Enclosing class:

JobExceptionsHandler

public static class JobExceptionsHandler.JobExceptionsJsonArchivist
extends Object
implements JsonArchivist

Archivist for the JobExceptionsHandler.

Constructor Summary

Constructors

Constructor and Description
JobExceptionsJsonArchivist()

Method Summary

Modifier and Type	Method and Description
Collection<ArchivedJson>	archiveJsonWithPath(AccessExecutionGraph graph) Returns a Collection of ArchivedJsons containing JSON responses and their respective REST URL for a given job.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobExceptionsJsonArchivist

public JobExceptionsJsonArchivist()

Method Detail

archiveJsonWithPath

public Collection<ArchivedJson> archiveJsonWithPath(AccessExecutionGraph graph)
                                             throws IOException

Description copied from interface: JsonArchivist

Returns a Collection of ArchivedJsons containing JSON responses and their respective REST URL for a given job.

The collection should contain one entry for every response that could be generated for the given job, for example one entry for each task. The REST URLs should be unique and must not contain placeholders.

Specified by:

archiveJsonWithPath in interface JsonArchivist

Parameters:

graph - AccessExecutionGraph for which the responses should be generated

Returns:

Collection containing an ArchivedJson for every response that could be generated for the given job

Throws:

IOException - thrown if the JSON generation fails