protected static class ClusterClient.LazyActorSystemLoader extends Object
ActorSystem
.Modifier and Type | Method and Description |
---|---|
akka.actor.ActorSystem |
get()
Creates a new ActorSystem or returns an existing one.
|
boolean |
isLoaded()
Indicates whether the ActorSystem has already been instantiated.
|
void |
shutdown() |
public boolean isLoaded()
public void shutdown()
public akka.actor.ActorSystem get() throws FlinkException
Exception
- if the ActorSystem could not be createdFlinkException
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.