Package | Description |
---|---|
org.apache.flink.runtime.akka | |
org.apache.flink.runtime.client | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.rest.handler.legacy | |
org.apache.flink.runtime.rest.handler.legacy.checkpoints | |
org.apache.flink.runtime.rest.handler.legacy.metrics | |
org.apache.flink.runtime.webmonitor | |
org.apache.flink.runtime.webmonitor.handlers.legacy | |
org.apache.flink.runtime.webmonitor.retriever.impl |
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 | Method and Description |
---|---|
static CompletableFuture<InetSocketAddress> |
JobClient.retrieveBlobServerAddress(JobManagerGateway jobManagerGateway,
Time timeout)
Utility method to retrieve the BlobServer address from the given JobManager gateway.
|
static ClassLoader |
JobClient.retrieveClassLoader(JobID jobID,
JobManagerGateway jobManager,
Configuration config,
HighAvailabilityServices highAvailabilityServices,
Time timeout)
Reconstructs the class loader by first requesting information about it at the JobManager
and then downloading missing jar files.
|
static void |
JobClient.submitJobDetached(JobManagerGateway jobManagerGateway,
Configuration config,
JobGraph jobGraph,
Time timeout,
ClassLoader classLoader)
Submits a job in detached mode.
|
Modifier and Type | Method and Description |
---|---|
static WebMonitor |
BootstrapTools.startWebMonitorIfConfigured(Configuration config,
HighAvailabilityServices highAvailabilityServices,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor,
org.slf4j.Logger logger)
Starts the web frontend.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<String> |
JobCancellationHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
TaskManagersHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
CurrentJobIdsHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
JobStoppingHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
AbstractExecutionGraphRequestHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
DashboardConfigHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
JobsOverviewHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<String> |
ClusterConfigHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
abstract CompletableFuture<String> |
AbstractJsonRequestHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway)
Core method that handles the request and generates the response.
|
CompletableFuture<String> |
ClusterOverviewHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
CompletableFuture<org.apache.flink.shaded.netty4.io.netty.handler.codec.http.FullHttpResponse> |
RequestHandler.handleRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway)
Core method that handles the request and generates the response.
|
CompletableFuture<org.apache.flink.shaded.netty4.io.netty.handler.codec.http.FullHttpResponse> |
AbstractJsonRequestHandler.handleRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
protected void |
TaskManagerLogHandler.respondAsLeader(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
RoutedRequest routedRequest,
JobManagerGateway jobManagerGateway)
Response when running with leading JobManager.
|
Constructor and Description |
---|
TaskManagerLogHandler(GatewayRetriever<JobManagerGateway> retriever,
Executor executor,
CompletableFuture<String> localJobManagerAddressPromise,
Time timeout,
TaskManagerLogHandler.FileMode fileMode,
Configuration config) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<String> |
CheckpointStatsDetailsSubtasksHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<String> |
AbstractMetricsHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
protected void |
RuntimeMonitorHandler.respondAsLeader(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
RoutedRequest routedRequest,
JobManagerGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
static WebMonitor |
WebMonitorUtils.startWebRuntimeMonitor(Configuration config,
HighAvailabilityServices highAvailabilityServices,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor)
Starts the web runtime monitor.
|
Constructor and Description |
---|
RuntimeMonitorHandler(WebMonitorConfig cfg,
RequestHandler handler,
GatewayRetriever<JobManagerGateway> retriever,
CompletableFuture<String> localJobManagerAddressFuture,
Time timeout) |
WebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<JobManagerGateway> |
AkkaJobManagerRetriever.createGateway(CompletableFuture<Tuple2<String,UUID>> leaderFuture) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.