public class Action
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Action.ActionContext
Context for Action's
|
Modifier and Type | Field and Description |
---|---|
protected HBaseCluster |
cluster |
protected Action.ActionContext |
context |
protected ServerName[] |
initialServers |
protected ClusterMetrics |
initialStatus |
protected static long |
KILL_DATANODE_TIMEOUT_DEFAULT |
static java.lang.String |
KILL_DATANODE_TIMEOUT_KEY |
protected static long |
KILL_MASTER_TIMEOUT_DEFAULT |
static java.lang.String |
KILL_MASTER_TIMEOUT_KEY |
protected static long |
KILL_RS_TIMEOUT_DEFAULT |
static java.lang.String |
KILL_RS_TIMEOUT_KEY |
protected static long |
KILL_ZK_NODE_TIMEOUT_DEFAULT |
static java.lang.String |
KILL_ZK_NODE_TIMEOUT_KEY |
protected long |
killDataNodeTimeout |
protected long |
killMasterTimeout |
protected long |
killRsTimeout |
protected long |
killZkNodeTimeout |
protected static Logger |
LOG |
protected static long |
START_DATANODE_TIMEOUT_DEFAULT |
static java.lang.String |
START_DATANODE_TIMEOUT_KEY |
protected static long |
START_MASTER_TIMEOUT_DEFAULT |
static java.lang.String |
START_MASTER_TIMEOUT_KEY |
protected static long |
START_RS_TIMEOUT_DEFAULT |
static java.lang.String |
START_RS_TIMEOUT_KEY |
protected static long |
START_ZK_NODE_TIMEOUT_DEFAULT |
static java.lang.String |
START_ZK_NODE_TIMEOUT_KEY |
protected long |
startDataNodeTimeout |
protected long |
startMasterTimeout |
protected long |
startRsTimeout |
protected long |
startZkNodeTimeout |
Constructor and Description |
---|
Action() |
Modifier and Type | Method and Description |
---|---|
protected void |
forceBalancer() |
Configuration |
getConf() |
protected ServerName[] |
getCurrentServers()
Returns current region servers - active master
|
void |
init(Action.ActionContext context) |
protected void |
killDataNode(ServerName server) |
protected void |
killMaster(ServerName server) |
protected void |
killRs(ServerName server) |
protected void |
killZKNode(ServerName server) |
protected void |
modifyAllTableColumns(TableName tableName,
java.util.function.BiConsumer<java.lang.String,ColumnFamilyDescriptorBuilder> transform)
Apply a transform to all columns in a given table.
|
protected void |
modifyAllTableColumns(TableName tableName,
java.util.function.Consumer<ColumnFamilyDescriptorBuilder> transform)
Apply a transform to all columns in a given table.
|
void |
perform() |
protected void |
startDataNode(ServerName server) |
protected void |
startMaster(ServerName server) |
protected void |
startRs(ServerName server) |
protected void |
startZKNode(ServerName server) |
protected void |
unbalanceRegions(ClusterMetrics clusterStatus,
java.util.List<ServerName> fromServers,
java.util.List<ServerName> toServers,
double fractionOfRegions) |
public static final java.lang.String KILL_MASTER_TIMEOUT_KEY
public static final java.lang.String START_MASTER_TIMEOUT_KEY
public static final java.lang.String KILL_RS_TIMEOUT_KEY
public static final java.lang.String START_RS_TIMEOUT_KEY
public static final java.lang.String KILL_ZK_NODE_TIMEOUT_KEY
public static final java.lang.String START_ZK_NODE_TIMEOUT_KEY
public static final java.lang.String KILL_DATANODE_TIMEOUT_KEY
public static final java.lang.String START_DATANODE_TIMEOUT_KEY
protected static final Logger LOG
protected static final long KILL_MASTER_TIMEOUT_DEFAULT
protected static final long START_MASTER_TIMEOUT_DEFAULT
protected static final long KILL_RS_TIMEOUT_DEFAULT
protected static final long START_RS_TIMEOUT_DEFAULT
protected static final long KILL_ZK_NODE_TIMEOUT_DEFAULT
protected static final long START_ZK_NODE_TIMEOUT_DEFAULT
protected static final long KILL_DATANODE_TIMEOUT_DEFAULT
protected static final long START_DATANODE_TIMEOUT_DEFAULT
protected Action.ActionContext context
protected HBaseCluster cluster
protected ClusterMetrics initialStatus
protected ServerName[] initialServers
protected long killMasterTimeout
protected long startMasterTimeout
protected long killRsTimeout
protected long startRsTimeout
protected long killZkNodeTimeout
protected long startZkNodeTimeout
protected long killDataNodeTimeout
protected long startDataNodeTimeout
public void init(Action.ActionContext context) throws java.io.IOException
java.io.IOException
public void perform() throws java.lang.Exception
java.lang.Exception
protected ServerName[] getCurrentServers() throws java.io.IOException
java.io.IOException
protected void killMaster(ServerName server) throws java.io.IOException
java.io.IOException
protected void startMaster(ServerName server) throws java.io.IOException
java.io.IOException
protected void killRs(ServerName server) throws java.io.IOException
java.io.IOException
protected void startRs(ServerName server) throws java.io.IOException
java.io.IOException
protected void killZKNode(ServerName server) throws java.io.IOException
java.io.IOException
protected void startZKNode(ServerName server) throws java.io.IOException
java.io.IOException
protected void killDataNode(ServerName server) throws java.io.IOException
java.io.IOException
protected void startDataNode(ServerName server) throws java.io.IOException
java.io.IOException
protected void unbalanceRegions(ClusterMetrics clusterStatus, java.util.List<ServerName> fromServers, java.util.List<ServerName> toServers, double fractionOfRegions) throws java.lang.Exception
java.lang.Exception
protected void forceBalancer() throws java.lang.Exception
java.lang.Exception
public Configuration getConf()
protected void modifyAllTableColumns(TableName tableName, java.util.function.BiConsumer<java.lang.String,ColumnFamilyDescriptorBuilder> transform) throws java.io.IOException
tableName
- the table to modifytransform
- the modification to perform. Callers will have the column name as a string and a column family builder available to themjava.io.IOException
protected void modifyAllTableColumns(TableName tableName, java.util.function.Consumer<ColumnFamilyDescriptorBuilder> transform) throws java.io.IOException
tableName
- the table to modifytransform
- the modification to perform on each column family descriptor builderjava.io.IOException