public abstract class ClusterStateUpdateTask extends Object
Constructor and Description |
---|
ClusterStateUpdateTask() |
Modifier and Type | Method and Description |
---|---|
abstract ClusterState |
execute(ClusterState currentState)
Update the cluster state based on the current state.
|
abstract void |
onFailure(String source,
Throwable t)
A callback called when execute fails.
|
void |
onNoLongerMaster(String source)
called when the task was rejected because the local node is no longer master
|
boolean |
runOnlyOnMaster()
indicates whether this task should only run if current node is master
|
public abstract ClusterState execute(ClusterState currentState) throws Exception
Exception
public abstract void onFailure(String source, Throwable t)
public boolean runOnlyOnMaster()
public void onNoLongerMaster(String source)
Copyright © 2009–2015. All rights reserved.