Package | Description |
---|---|
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.testutils | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
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.Tuple5<akka.actor.ActorSystem,akka.actor.ActorRef,akka.actor.ActorRef,scala.Option<WebMonitor>,scala.Option<akka.actor.ActorRef>> |
JobManager.startActorSystemAndJobManagerActors(Configuration configuration,
JobManagerMode executionMode,
String listeningAddress,
int listeningPort,
Executor futureExecutor,
Executor ioExecutor,
Class<? extends JobManager> jobManagerClass,
Class<? extends MemoryArchivist> archiveClass,
scala.Option<Class<? extends FlinkResourceManager<?>>> resourceManagerClass)
Starts an ActorSystem, the JobManager and all its components including the WebMonitor.
|
scala.Tuple5<akka.actor.ActorSystem,akka.actor.ActorRef,akka.actor.ActorRef,scala.Option<WebMonitor>,scala.Option<akka.actor.ActorRef>> |
JobManager$.startActorSystemAndJobManagerActors(Configuration configuration,
JobManagerMode executionMode,
String listeningAddress,
int listeningPort,
Executor futureExecutor,
Executor ioExecutor,
Class<? extends JobManager> jobManagerClass,
Class<? extends MemoryArchivist> archiveClass,
scala.Option<Class<? extends FlinkResourceManager<?>>> resourceManagerClass)
Starts an ActorSystem, the JobManager and all its components including the WebMonitor.
|
Modifier and Type | Class and Description |
---|---|
class |
TestingResourceManager
A testing resource manager which may alter the default standalone resource master's behavior.
|
Modifier and Type | Class and Description |
---|---|
class |
YarnFlinkResourceManager
Specialized Flink Resource Manager implementation for YARN clusters.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.