Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.clusterframework.standalone | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.yarn |
Modifier and Type | Class and Description |
---|---|
class |
MesosFlinkResourceManager
Flink Resource Manager for Apache Mesos.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
StandaloneResourceManager
A standalone implementation of the resource manager.
|
Modifier and Type | Method and Description |
---|---|
static scala.Tuple4<akka.actor.ActorRef,akka.actor.ActorRef,scala.Option<WebMonitor>,scala.Option<akka.actor.ActorRef>> |
JobManager.startJobManagerActors(akka.actor.ActorSystem jobManagerSystem,
Configuration configuration,
JobManagerMode executionMode,
String externalHostname,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
HighAvailabilityServices highAvailabilityServices,
Class<? extends JobManager> jobManagerClass,
Class<? extends MemoryArchivist> archiveClass,
scala.Option<Class<? extends FlinkResourceManager<?>>> resourceManagerClass)
Starts the JobManager and all its components including the WebMonitor.
|
scala.Tuple4<akka.actor.ActorRef,akka.actor.ActorRef,scala.Option<WebMonitor>,scala.Option<akka.actor.ActorRef>> |
JobManager$.startJobManagerActors(akka.actor.ActorSystem jobManagerSystem,
Configuration configuration,
JobManagerMode executionMode,
String externalHostname,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
HighAvailabilityServices highAvailabilityServices,
Class<? extends JobManager> jobManagerClass,
Class<? extends MemoryArchivist> archiveClass,
scala.Option<Class<? extends FlinkResourceManager<?>>> resourceManagerClass)
Starts the JobManager and all its components including the WebMonitor.
|
Modifier and Type | Method and Description |
---|---|
akka.actor.Props |
LocalFlinkMiniCluster.getResourceManagerProps(Class<? extends FlinkResourceManager<? extends ResourceIDRetrievable>> resourceManagerClass,
Configuration configuration,
LeaderRetrievalService leaderRetrievalService) |
Modifier and Type | Class and Description |
---|---|
class |
YarnFlinkResourceManager
Specialized Flink Resource Manager implementation for YARN clusters.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.