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