Modifier and Type | Class and Description |
---|---|
class |
JobClientActor
Actor which constitutes the bridge between the non-actor code and the JobManager.
|
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. |
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 |
ForkableFlinkMiniCluster
A forkable mini cluster is a special case of the mini cluster, used for parallel test execution
on build servers.
|
Modifier and Type | Class and Description |
---|---|
class |
ApplicationClient
Actor which is responsible to repeatedly poll the Yarn cluster status from the JobManager.
|
class |
YarnTaskManager
An extension of the TaskManager that listens for additional YARN related
messages.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.