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.webmonitor | |
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 |
---|---|
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 |
---|
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.