Package org.apache.flink.runtime.webmonitor.handlers.utils

Class JarHandlerUtils.JarHandlerContext

java.lang.Object

org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils.JarHandlerContext

Enclosing class:

JarHandlerUtils

public static class JarHandlerUtils.JarHandlerContext
extends Object

Standard jar handler parameters parsed from request.

Method Summary

Modifier and Type	Method	Description
void	applyToConfiguration(Configuration configuration, HandlerRequest<? extends JarRequestBody> request)
static <R extends JarRequestBody> JarHandlerUtils.JarHandlerContext	fromRequest(HandlerRequest<R> request, Path jarDir, org.slf4j.Logger log)
JobGraph	toJobGraph(PackagedProgram packagedProgram, Configuration configuration, boolean suppressOutput)
PackagedProgram	toPackagedProgram(Configuration configuration)

Methods inherited from class java.lang.Object

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

Method Detail

fromRequest

public static <R extends JarRequestBody> JarHandlerUtils.JarHandlerContext fromRequest(@Nonnull
                                                                                       HandlerRequest<R> request,
                                                                                       @Nonnull
                                                                                       Path jarDir,
                                                                                       @Nonnull
                                                                                       org.slf4j.Logger log)
                                                                                throws RestHandlerException

Throws:

RestHandlerException

applyToConfiguration

public void applyToConfiguration(Configuration configuration,
                                 HandlerRequest<? extends JarRequestBody> request)

toJobGraph

public JobGraph toJobGraph(PackagedProgram packagedProgram,
                           Configuration configuration,
                           boolean suppressOutput)

toPackagedProgram

public PackagedProgram toPackagedProgram(Configuration configuration)