Modifier and Type | Method and Description |
---|---|
protected ActorGateway |
CliFrontend.getJobManagerGateway(CommandLineOptions options)
Retrieves the
ActorGateway for the JobManager. |
Modifier and Type | Method and Description |
---|---|
ActorGateway |
ClusterClient.getJobManagerGateway()
Returns the
ActorGateway of the current job manager leader using
the LeaderRetrievalService . |
Modifier and Type | Method and Description |
---|---|
static List<BlobKey> |
BlobClient.uploadJarFiles(ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration askTimeout,
Configuration clientConfig,
List<Path> jars)
Retrieves the
BlobServer address from the JobManager and uploads
the JAR files to it. |
Modifier and Type | Method and Description |
---|---|
static JobListeningContext |
JobClient.attachToRunningJob(JobID jobID,
ActorGateway jobManagerGateWay,
Configuration configuration,
akka.actor.ActorSystem actorSystem,
HighAvailabilityServices highAvailabilityServices,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates)
Attaches to a running Job using the JobID.
|
static ClassLoader |
JobClient.retrieveClassLoader(JobID jobID,
ActorGateway jobManager,
Configuration config,
HighAvailabilityServices highAvailabilityServices)
Reconstructs the class loader by first requesting information about it at the JobManager
and then downloading missing jar files.
|
static void |
JobClient.submitJobDetached(ActorGateway jobManagerGateway,
Configuration config,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
ClassLoader classLoader)
Submits a job in detached mode.
|
Modifier and Type | Class and Description |
---|---|
class |
AkkaActorGateway
Concrete
ActorGateway implementation which uses Akka to communicate with remote actors. |
Modifier and Type | Method and Description |
---|---|
void |
AkkaActorGateway.forward(Object message,
ActorGateway sender)
Forwards a message.
|
void |
ActorGateway.forward(Object message,
ActorGateway sender)
Forwards a message.
|
void |
AkkaActorGateway.tell(Object message,
ActorGateway sender)
Sends a message asynchronously without a result with sender being the sender.
|
void |
ActorGateway.tell(Object message,
ActorGateway sender)
Sends a message asynchronously without a result with sender being the sender.
|
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.uploadUserJars(ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration askTimeout,
Configuration blobClientConfig)
Uploads the previously added user JAR files to the job manager through
the job manager's BLOB server.
|
Modifier and Type | Method and Description |
---|---|
ActorGateway |
ActorTaskManagerGateway.getActorGateway() |
Constructor and Description |
---|
ActorTaskManagerGateway(ActorGateway actorGateway) |
Modifier and Type | Method and Description |
---|---|
ActorGateway |
FlinkMiniCluster.getLeaderGateway(scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<ActorGateway> |
FlinkMiniCluster.getLeaderGatewayFuture() |
scala.concurrent.Promise<ActorGateway> |
FlinkMiniCluster.leaderGateway()
Future to the
ActorGateway of the current leader |
Constructor and Description |
---|
ActorGatewayCheckpointResponder(ActorGateway actorGateway) |
ActorGatewayKvStateRegistryListener(ActorGateway jobManager,
KvStateServerAddress kvStateServerAddress) |
ActorGatewayPartitionProducerStateChecker(ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration timeout) |
ActorGatewayResultPartitionConsumableNotifier(scala.concurrent.ExecutionContext executionContext,
ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration jobManagerMessageTimeout) |
ActorGatewayTaskExecutionStateListener(ActorGateway actorGateway) |
ActorGatewayTaskManagerActions(ActorGateway actorGateway) |
TaskInputSplitProvider(ActorGateway jobManager,
JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionID,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
static ActorGateway |
LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalService leaderRetrievalService,
akka.actor.ActorSystem actorSystem,
scala.concurrent.duration.FiniteDuration timeout)
Retrieves the current leader gateway using the given
LeaderRetrievalService . |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<ActorGateway> |
LeaderRetrievalUtils.LeaderGatewayListener.getActorGatewayFuture() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<ActorGateway,Integer> |
JobManagerRetriever.awaitJobManagerGatewayAndWebPort()
Awaits the leading job manager gateway and its web monitor port.
|
scala.Option<scala.Tuple2<ActorGateway,Integer>> |
JobManagerRetriever.getJobManagerGatewayAndWebPort()
Returns the currently known leading job manager gateway and its web monitor port.
|
Modifier and Type | Method and Description |
---|---|
AccessExecutionGraph |
ExecutionGraphHolder.getExecutionGraph(JobID jid,
ActorGateway jobManager)
Retrieves the execution graph with
JobID jid or null if it cannot be found. |
protected abstract void |
RuntimeMonitorHandlerBase.respondAsLeader(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.router.Routed routed,
ActorGateway jobManager) |
protected void |
RuntimeMonitorHandler.respondAsLeader(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.router.Routed routed,
ActorGateway jobManager) |
Modifier and Type | Method and Description |
---|---|
String |
TaskManagersHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JobStoppingHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JobManagerConfigHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JobCancellationHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JarUploadHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JarRunHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JarPlanHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JarListHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JarDeleteHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
JarAccessDeniedHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
DashboardConfigHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
CurrentJobsOverviewHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
CurrentJobIdsHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
String |
ClusterOverviewHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
abstract String |
AbstractJsonRequestHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager)
Core method that handles the request and generates the response.
|
String |
AbstractExecutionGraphRequestHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
io.netty.handler.codec.http.FullHttpResponse |
RequestHandler.handleRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager)
Core method that handles the request and generates the response.
|
io.netty.handler.codec.http.FullHttpResponse |
AbstractJsonRequestHandler.handleRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
protected void |
TaskManagerLogHandler.respondAsLeader(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.router.Routed routed,
ActorGateway jobManager)
Response when running with leading JobManager.
|
Modifier and Type | Method and Description |
---|---|
static String |
HandlerRedirectUtils.getRedirectAddress(String localJobManagerAddress,
scala.Tuple2<ActorGateway,Integer> leader) |
Modifier and Type | Method and Description |
---|---|
String |
CheckpointStatsDetailsSubtasksHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
Modifier and Type | Method and Description |
---|---|
String |
AbstractMetricsHandler.handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
ActorGateway jobManager) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.