Package | Description |
---|---|
org.apache.flink.client.program |
Modifier and Type | Class and Description |
---|---|
protected static class |
ClusterClient.LazyActorSystemLoader
Utility class to lazily instantiate an
ActorSystem . |
class |
DefaultActorSystemLoader
ActorSystemLoader which simply returns the given ActorSystem at
construction time. |
Modifier and Type | Field and Description |
---|---|
protected ActorSystemLoader |
ClusterClient.actorSystemLoader
The actor system used to communicate with the JobManager.
|
Constructor and Description |
---|
ClusterClient(Configuration flinkConfig,
HighAvailabilityServices highAvailabilityServices,
boolean sharedHaServices,
ActorSystemLoader actorSystemLoader) |
StandaloneClusterClient(Configuration config,
HighAvailabilityServices highAvailabilityServices,
boolean sharedHaServices,
ActorSystemLoader actorSystemLoader) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.