Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
JobClientActor.createJobClientActorProps(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates) |
static JobExecutionResult |
JobClient.submitJobAndWait(akka.actor.ActorSystem actorSystem,
LeaderRetrievalService leaderRetrievalService,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
the JobManager.
|
Constructor and Description |
---|
JobClientActor(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates) |
Modifier and Type | Class and Description |
---|---|
class |
StandaloneLeaderRetrievalService
Standalone implementation of the
LeaderRetrievalService . |
class |
ZooKeeperLeaderRetrievalService
The counterpart to the
ZooKeeperLeaderElectionService . |
Modifier and Type | Method and Description |
---|---|
protected LeaderRetrievalService |
FlinkMiniCluster.createLeaderRetrievalService() |
Modifier and Type | Method and Description |
---|---|
protected scala.Option<LeaderRetrievalService> |
FlinkMiniCluster.leaderRetrievalService() |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates,
scala.concurrent.duration.FiniteDuration timeout,
LeaderRetrievalService leaderRetrievalService) |
Modifier and Type | Method and Description |
---|---|
protected LeaderRetrievalService |
TaskManager.leaderRetrievalService() |
Modifier and Type | Method and Description |
---|---|
akka.actor.ActorRef |
TaskManager$.startTaskManagerComponentsAndActor(Configuration configuration,
akka.actor.ActorSystem actorSystem,
String taskManagerHostname,
scala.Option<String> taskManagerActorName,
scala.Option<LeaderRetrievalService> leaderRetrievalServiceOption,
boolean localTaskManagerCommunication,
Class<? extends TaskManager> taskManagerClass) |
static akka.actor.ActorRef |
TaskManager.startTaskManagerComponentsAndActor(Configuration configuration,
akka.actor.ActorSystem actorSystem,
String taskManagerHostname,
scala.Option<String> taskManagerActorName,
scala.Option<LeaderRetrievalService> leaderRetrievalServiceOption,
boolean localTaskManagerCommunication,
Class<? extends TaskManager> taskManagerClass) |
Constructor and Description |
---|
TaskManager(TaskManagerConfiguration config,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
Modifier and Type | Method and Description |
---|---|
static LeaderRetrievalService |
LeaderRetrievalUtils.createLeaderRetrievalService(Configuration configuration)
Creates a
LeaderRetrievalService based on the provided Configuration object. |
Modifier and Type | Method and Description |
---|---|
static InetAddress |
LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout) |
static LeaderConnectionInfo |
LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout)
Retrieves the leader akka url and the current leader session ID.
|
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 |
---|---|
static WebMonitor |
WebMonitorUtils.startWebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
akka.actor.ActorSystem actorSystem)
Starts the web runtime monitor.
|
Constructor and Description |
---|
WebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
akka.actor.ActorSystem actorSystem) |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalService |
ApplicationClient.leaderRetrievalService() |
Constructor and Description |
---|
ApplicationClient(Configuration flinkConfig,
LeaderRetrievalService leaderRetrievalService) |
YarnTaskManager(TaskManagerConfiguration config,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.