org.apache.flink.runtime.webmonitor

Class WebMonitorUtils

java.lang.Object

org.apache.flink.runtime.webmonitor.WebMonitorUtils

public final class WebMonitorUtils
extends Object

Utilities for the web runtime monitor. This class contains for example methods to build messages with aggregate information about the state of an execution graph, to be send to the web server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WebMonitorUtils.LogFileLocation Singleton to hold the log file, the stdout file, the log directory.

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	fromKeyValueJsonArray(String jsonString)
static WebMonitorExtension	loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path uploadDir, Executor executor, Configuration configuration) Loads the WebMonitorExtension which enables web submission.
static <T extends RestfulGateway> Optional<StaticFileServerHandler<T>>	tryLoadWebContent(GatewayRetriever<? extends T> leaderRetriever, Time timeout, File tmpDir) Checks whether the flink-runtime-web dependency is available and if so returns a StaticFileServerHandler which can serve the static file contents.
static Path	validateAndNormalizeUri(URI archiveDirUri) Checks and normalizes the given URI.

Methods inherited from class java.lang.Object

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

Method Detail

tryLoadWebContent

public static <T extends RestfulGateway> Optional<StaticFileServerHandler<T>> tryLoadWebContent(GatewayRetriever<? extends T> leaderRetriever,
                                                                                                Time timeout,
                                                                                                File tmpDir)
                                                                                         throws IOException

Checks whether the flink-runtime-web dependency is available and if so returns a StaticFileServerHandler which can serve the static file contents.

Type Parameters:

T - type of the gateway to retrieve

Parameters:

leaderRetriever - to be used by the StaticFileServerHandler

timeout - for lookup requests

tmpDir - to be used by the StaticFileServerHandler to store temporary files

Returns:

StaticFileServerHandler if flink-runtime-web is in the classpath; Otherwise Optional.empty

Throws:

IOException - if we cannot create the StaticFileServerHandler

loadWebSubmissionExtension

public static WebMonitorExtension loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
                                                             Time timeout,
                                                             Map<String,String> responseHeaders,
                                                             CompletableFuture<String> localAddressFuture,
                                                             Path uploadDir,
                                                             Executor executor,
                                                             Configuration configuration)
                                                      throws FlinkException

Loads the WebMonitorExtension which enables web submission.

Parameters:

leaderRetriever - to retrieve the leader

timeout - for asynchronous requests

responseHeaders - for the web submission handlers

localAddressFuture - of the underlying REST server endpoint

uploadDir - where the web submission handler store uploaded jars

executor - to run asynchronous operations

configuration - used to instantiate the web submission extension

Returns:

Web submission extension

Throws:

FlinkException - if the web submission extension could not be loaded

fromKeyValueJsonArray

public static Map<String,String> fromKeyValueJsonArray(String jsonString)

validateAndNormalizeUri

public static Path validateAndNormalizeUri(URI archiveDirUri)

Checks and normalizes the given URI. This method first checks the validity of the URI (scheme and path are not null) and then normalizes the URI to a path.

Parameters:

archiveDirUri - The URI to check and normalize.

Returns:

A normalized URI as a Path.

Throws:

IllegalArgumentException - Thrown, if the URI misses scheme or path.