Constructor and Description |
---|
RestClusterClient(Configuration config,
T clusterId,
LeaderRetrievalService webMonitorRetrievalService) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
MesosFlinkResourceManager.createActorProps(Class<? extends MesosFlinkResourceManager> actorClass,
Configuration flinkConfig,
MesosConfiguration mesosConfig,
MesosWorkerStore workerStore,
LeaderRetrievalService leaderRetrievalService,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
MesosArtifactResolver artifactResolver,
org.slf4j.Logger log)
Creates the props needed to instantiate this actor.
|
Constructor and Description |
---|
MesosFlinkResourceManager(Configuration flinkConfig,
MesosConfiguration mesosConfig,
MesosWorkerStore workerStore,
LeaderRetrievalService leaderRetrievalService,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
MesosArtifactResolver artifactResolver,
int maxFailedTasks,
int numInitialTaskManagers) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
JobAttachmentClientActor.createActorProps(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates) |
static akka.actor.Props |
JobSubmissionClientActor.createActorProps(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates,
Configuration clientConfig) |
Constructor and Description |
---|
JobAttachmentClientActor(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates) |
JobClientActor(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates) |
JobSubmissionClientActor(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates,
Configuration clientConfig) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
FlinkResourceManager.getResourceManagerProps(Class<? extends FlinkResourceManager> resourceManagerClass,
Configuration configuration,
LeaderRetrievalService leaderRetrievalService) |
static akka.actor.ActorRef |
FlinkResourceManager.startResourceManagerActors(Configuration configuration,
akka.actor.ActorSystem actorSystem,
LeaderRetrievalService leaderRetriever,
Class<? extends FlinkResourceManager<?>> resourceManagerClass)
Starts the resource manager actors.
|
static akka.actor.ActorRef |
FlinkResourceManager.startResourceManagerActors(Configuration configuration,
akka.actor.ActorSystem actorSystem,
LeaderRetrievalService leaderRetriever,
Class<? extends FlinkResourceManager<?>> resourceManagerClass,
String resourceManagerActorName)
Starts the resource manager actors.
|
Constructor and Description |
---|
FlinkResourceManager(int numInitialTaskManagers,
Configuration flinkConfig,
LeaderRetrievalService leaderRetriever)
Creates a AbstractFrameworkMaster actor.
|
Constructor and Description |
---|
StandaloneResourceManager(Configuration flinkConfig,
LeaderRetrievalService leaderRetriever) |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalService |
HighAvailabilityServices.getDispatcherLeaderRetriever()
Gets the leader retriever for the dispatcher.
|
LeaderRetrievalService |
HighAvailabilityServices.getJobManagerLeaderRetriever(JobID jobID)
Deprecated.
This method should only be used by the legacy code where the JobManager acts as the master.
|
LeaderRetrievalService |
HighAvailabilityServices.getJobManagerLeaderRetriever(JobID jobID,
String defaultJobManagerAddress)
Gets the leader retriever for the job JobMaster which is responsible for the given job
|
LeaderRetrievalService |
HighAvailabilityServices.getResourceManagerLeaderRetriever()
Gets the leader retriever for the cluster's resource manager.
|
LeaderRetrievalService |
HighAvailabilityServices.getWebMonitorLeaderRetriever() |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalService |
EmbeddedLeaderService.createLeaderRetrievalService() |
LeaderRetrievalService |
EmbeddedHaServices.getDispatcherLeaderRetriever() |
LeaderRetrievalService |
EmbeddedHaServices.getJobManagerLeaderRetriever(JobID jobID) |
LeaderRetrievalService |
EmbeddedHaServices.getJobManagerLeaderRetriever(JobID jobID,
String defaultJobManagerAddress) |
LeaderRetrievalService |
EmbeddedHaServices.getResourceManagerLeaderRetriever() |
LeaderRetrievalService |
EmbeddedHaServices.getWebMonitorLeaderRetriever() |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalService |
SingleLeaderElectionService.createLeaderRetrievalService() |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalService |
StandaloneHaServices.getDispatcherLeaderRetriever() |
LeaderRetrievalService |
StandaloneHaServices.getJobManagerLeaderRetriever(JobID jobID) |
LeaderRetrievalService |
StandaloneHaServices.getJobManagerLeaderRetriever(JobID jobID,
String defaultJobManagerAddress) |
LeaderRetrievalService |
StandaloneHaServices.getResourceManagerLeaderRetriever() |
LeaderRetrievalService |
StandaloneHaServices.getWebMonitorLeaderRetriever() |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalService |
ZooKeeperHaServices.getDispatcherLeaderRetriever() |
LeaderRetrievalService |
ZooKeeperHaServices.getJobManagerLeaderRetriever(JobID jobID) |
LeaderRetrievalService |
ZooKeeperHaServices.getJobManagerLeaderRetriever(JobID jobID,
String defaultJobManagerAddress) |
LeaderRetrievalService |
ZooKeeperHaServices.getResourceManagerLeaderRetriever() |
LeaderRetrievalService |
ZooKeeperHaServices.getWebMonitorLeaderRetriever() |
Modifier and Type | Class and Description |
---|---|
class |
SettableLeaderRetrievalService
LeaderRetrievalService implementation which directly forwards calls of
notifyListener to the listener. |
class |
StandaloneLeaderRetrievalService
Standalone implementation of the
LeaderRetrievalService . |
class |
ZooKeeperLeaderRetrievalService
The counterpart to the
ZooKeeperLeaderElectionService . |
Modifier and Type | Method and Description |
---|---|
static InetAddress |
LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout) |
static InetAddress |
LeaderRetrievalUtils.findConnectingAddress(LeaderRetrievalService leaderRetrievalService,
Time timeout) |
static LeaderConnectionInfo |
LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout)
Retrieves the leader akka url and the current leader session ID.
|
static LeaderConnectionInfo |
LeaderRetrievalUtils.retrieveLeaderConnectionInfo(LeaderRetrievalService leaderRetrievalService,
Time 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 . |
static UUID |
LeaderRetrievalUtils.retrieveLeaderSessionId(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout)
Retrieves the current leader session id of the component identified by the given leader
retrieval service.
|
Constructor and Description |
---|
WebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
LeaderGatewayRetriever<JobManagerGateway> jobManagerRetriever,
MetricQueryServiceRetriever queryServiceRetriever,
Time timeout,
ScheduledExecutor scheduledExecutor) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
YarnFlinkResourceManager.createActorProps(Class<? extends YarnFlinkResourceManager> actorClass,
Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webFrontendURL,
ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int numInitialTaskManagers,
org.slf4j.Logger log)
Creates the props needed to instantiate this actor.
|
Constructor and Description |
---|
YarnFlinkResourceManager(Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webInterfaceURL,
ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int yarnHeartbeatIntervalMillis,
int maxFailedContainers,
int numInitialTaskManagers) |
YarnFlinkResourceManager(Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webInterfaceURL,
ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int yarnHeartbeatIntervalMillis,
int maxFailedContainers,
int numInitialTaskManagers,
YarnResourceManagerCallbackHandler callbackHandler) |
YarnFlinkResourceManager(Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webInterfaceURL,
ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int yarnHeartbeatIntervalMillis,
int maxFailedContainers,
int numInitialTaskManagers,
YarnResourceManagerCallbackHandler callbackHandler,
org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest> resourceManagerClient,
org.apache.hadoop.yarn.client.api.NMClient nodeManagerClient) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.