Modifier and Type | Class and Description |
---|---|
class |
AkkaJobManagerGateway
Implementation of the
JobManagerGateway for old JobManager code based
on Akka actors and the ActorGateway . |
Modifier and Type | Interface and Description |
---|---|
interface |
DispatcherGateway
Gateway for the Dispatcher component.
|
Modifier and Type | Class and Description |
---|---|
class |
Dispatcher
Base class for the Dispatcher component.
|
class |
StandaloneDispatcher
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobManagerGateway
Public JobManager gateway.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRestHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
Super class for netty-based handlers that work with
RequestBody s and ResponseBody s. |
interface |
LegacyRestHandler<T extends RestfulGateway,R extends ResponseBody,M extends MessageParameters>
Interface which Flink's legacy REST handler have to implement in order to be usable
via the
LegacyRestHandlerAdapter . |
class |
LegacyRestHandlerAdapter<T extends RestfulGateway,R extends ResponseBody,M extends MessageParameters>
Adapter for Flink's legacy REST handlers.
|
class |
RedirectHandler<T extends RestfulGateway>
SimpleChannelInboundHandler which encapsulates the redirection logic for the
REST endpoints. |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<R> |
AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<AccessExecutionGraph> |
ExecutionGraphCache.getExecutionGraph(JobID jobId,
RestfulGateway restfulGateway)
Gets the
AccessExecutionGraph for the given JobID and caches it. |
Modifier and Type | Class and Description |
---|---|
class |
StaticFileServerHandler<T extends RestfulGateway>
Simple file server handler that serves requests to web frontend's static files, such as
HTML, CSS, or JS files.
|
Modifier and Type | Class and Description |
---|---|
class |
MetricFetcher<T extends RestfulGateway>
The MetricFetcher can be used to fetch metrics from the JobManager and all registered TaskManagers.
|
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<Optional<String>> |
HandlerRedirectUtils.getRedirectAddress(String localRestAddress,
RestfulGateway restfulGateway,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
static <T extends RestfulGateway> |
WebMonitorUtils.tryLoadWebContent(GatewayRetriever<T> leaderRetriever,
CompletableFuture<String> restAddressFuture,
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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.