Package | Description |
---|---|
org.apache.flink.runtime.taskmanager | |
org.apache.flink.runtime.testingUtils | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
void |
TaskManager$.runTaskManager(String taskManagerHostname,
ResourceID resourceID,
int actorSystemPort,
Configuration configuration,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
static void |
TaskManager.runTaskManager(String taskManagerHostname,
ResourceID resourceID,
int actorSystemPort,
Configuration configuration,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
void |
TaskManager$.selectNetworkInterfaceAndRunTaskManager(Configuration configuration,
ResourceID resourceID,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
static void |
TaskManager.selectNetworkInterfaceAndRunTaskManager(Configuration configuration,
ResourceID resourceID,
Class<? extends TaskManager> taskManagerClass)
Starts and runs the TaskManager.
|
akka.actor.ActorRef |
TaskManager$.startTaskManagerComponentsAndActor(Configuration configuration,
ResourceID resourceID,
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,
ResourceID resourceID,
akka.actor.ActorSystem actorSystem,
String taskManagerHostname,
scala.Option<String> taskManagerActorName,
scala.Option<LeaderRetrievalService> leaderRetrievalServiceOption,
boolean localTaskManagerCommunication,
Class<? extends TaskManager> taskManagerClass) |
Modifier and Type | Class and Description |
---|---|
class |
TestingTaskManager
Subclass of the
TaskManager to support testing messages |
Modifier and Type | Class and Description |
---|---|
class |
YarnTaskManager
An extension of the TaskManager that listens for additional YARN related
messages.
|
Modifier and Type | Method and Description |
---|---|
protected Class<? extends TaskManager> |
YarnApplicationMasterRunner.getTaskManagerClass() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.