Modifier and Type | Class and Description |
---|---|
class |
MesosTaskManager
An extension of the TaskManager that listens for additional Mesos-related
messages.
|
Modifier and Type | Class and Description |
---|---|
class |
JobAttachmentClientActor
Actor which handles Job attachment process and provides Job updates until completion.
|
class |
JobClientActor
Actor which constitutes the bridge between the non-actor code and the JobManager.
|
class |
JobSubmissionClientActor
Actor which handles Job submission process and provides Job updates until completion.
|
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperLeaderRetrievalService.start(LeaderRetrievalListener listener) |
void |
StandaloneLeaderRetrievalService.start(LeaderRetrievalListener listener) |
void |
LeaderRetrievalService.start(LeaderRetrievalListener listener)
Starts the leader retrieval service with the given listener to listen for new leaders.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkMiniCluster
Abstract base class for Flink's mini cluster.
|
class |
LocalFlinkMiniCluster
Local Flink mini cluster which executes all
TaskManager s and the JobManager in the same
JVM. |
class |
OneTimeLeaderListenerFuture
A leader listener that exposes a future for the first leader notification.
|
Modifier and Type | Class and Description |
---|---|
static class |
ConnectionUtils.LeaderConnectingAddressListener |
Modifier and Type | Class and Description |
---|---|
class |
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
Modifier and Type | Class and Description |
---|---|
static class |
LeaderRetrievalUtils.LeaderConnectionInfoListener
Helper class which is used by the retrieveLeaderConnectionInfo method to retrieve the
leader's akka URL and the current leader session ID.
|
static class |
LeaderRetrievalUtils.LeaderGatewayListener
Helper class which is used by the retrieveLeaderGateway method as the
LeaderRetrievalListener . |
Modifier and Type | Class and Description |
---|---|
class |
JobManagerRetriever
Retrieves and stores the actor gateway to the current leading JobManager.
|
Modifier and Type | Class and Description |
---|---|
class |
ApplicationClient
Actor which is responsible to repeatedly poll the Yarn cluster status from the ResourceManager.
|
class |
YarnTaskManager
An extension of the TaskManager that listens for additional YARN related
messages.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.