org.apache.flink.runtime.dispatcher

Interface HistoryServerArchivist

All Known Implementing Classes:

VoidHistoryServerArchivist

public interface HistoryServerArchivist

Writer for an AccessExecutionGraph.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	archiveExecutionGraph(AccessExecutionGraph executionGraph) Archives the given AccessExecutionGraph on the history server.
static HistoryServerArchivist	createHistoryServerArchivist(Configuration configuration, JsonArchivist jsonArchivist, Executor ioExecutor)

Method Detail

archiveExecutionGraph

CompletableFuture<Acknowledge> archiveExecutionGraph(AccessExecutionGraph executionGraph)

Archives the given AccessExecutionGraph on the history server.

Parameters:

executionGraph - to store on the history server

Returns:

Future which is completed once the archiving has been completed.

createHistoryServerArchivist

static HistoryServerArchivist createHistoryServerArchivist(Configuration configuration,
                                                           JsonArchivist jsonArchivist,
                                                           Executor ioExecutor)