Modifier and Type | Method and Description |
---|---|
akka.actor.ActorSystem |
ClusterClient.LazyActorSystemLoader.get()
Creates a new ActorSystem or returns an existing one.
|
Modifier and Type | Method and Description |
---|---|
static void |
MasterHooks.restoreMasterHooks(Map<String,MasterTriggerRestoreHook<?>> masterHooks,
Collection<MasterState> states,
long checkpointId,
boolean allowUnmatchedState,
org.slf4j.Logger log)
Calls the restore method given checkpoint master hooks and passes the given master
state to them where state with a matching name is found.
|
static List<MasterState> |
MasterHooks.triggerMasterHooks(Collection<MasterTriggerRestoreHook<?>> hooks,
long checkpointId,
long timestamp,
Executor executor,
Time timeout)
Triggers all given master hooks and returns state objects for each hook that
produced a state.
|
Constructor and Description |
---|
HistoryServer(Configuration config) |
HistoryServer(Configuration config,
CountDownLatch numFinishedPolls) |
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperStateHandleStore.RemoveCallback.apply(RetrievableStateHandle<T> value)
Callback method.
|
Modifier and Type | Method and Description |
---|---|
void |
ExternallyInducedSource.CheckpointTrigger.triggerCheckpoint(long checkpointId)
Triggers a checkpoint.
|
Modifier and Type | Class and Description |
---|---|
class |
ConfigurationException
Exception which occurs when creating a configuration object fails.
|
class |
DynamicCodeLoadingException
An exception that is thrown if the dynamic instantiation of code fails.
|
class |
StateMigrationException
Base class for state migration related exceptions
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.