@InterfaceAudience.Private @InterfaceStability.Evolving public final class MasterProcedureUtil extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
MasterProcedureUtil.NonceProcedureRunnable
Helper Runnable used in conjunction with submitProcedure() to deal with
submitting procs with nonce.
|
Modifier and Type | Method and Description |
---|---|
static HBaseProtos.ProcedureDescription |
buildProcedure(java.lang.String signature,
java.lang.String instance,
java.util.Map<java.lang.String,java.lang.String> props) |
static long |
execProcedure(MasterProcedureManager mpm,
java.lang.String signature,
java.lang.String instance,
java.util.Map<java.lang.String,java.lang.String> props) |
static long |
submitProcedure(MasterProcedureUtil.NonceProcedureRunnable runnable)
Helper used to deal with submitting procs with nonce.
|
static RPCProtos.UserInformation |
toProtoUserInfo(UserGroupInformation ugi) |
static UserGroupInformation |
toUserInfo(RPCProtos.UserInformation userInfoProto) |
static void |
waitForProcedure(MasterProcedureManager mpm,
java.lang.String signature,
java.lang.String instance,
java.util.Map<java.lang.String,java.lang.String> props,
long max,
int numRetries,
long pause) |
public static RPCProtos.UserInformation toProtoUserInfo(UserGroupInformation ugi)
public static UserGroupInformation toUserInfo(RPCProtos.UserInformation userInfoProto)
public static HBaseProtos.ProcedureDescription buildProcedure(java.lang.String signature, java.lang.String instance, java.util.Map<java.lang.String,java.lang.String> props)
public static long execProcedure(MasterProcedureManager mpm, java.lang.String signature, java.lang.String instance, java.util.Map<java.lang.String,java.lang.String> props) throws java.io.IOException
java.io.IOException
public static void waitForProcedure(MasterProcedureManager mpm, java.lang.String signature, java.lang.String instance, java.util.Map<java.lang.String,java.lang.String> props, long max, int numRetries, long pause) throws java.io.IOException
java.io.IOException
public static long submitProcedure(MasterProcedureUtil.NonceProcedureRunnable runnable) throws java.io.IOException
long procId = MasterProcedureUtil.submitProcedure(
new NonceProcedureRunnable(procExec, nonceGroup, nonce) {
@Override
public void run() {
cpHost.preOperation();
submitProcedure(new MyProc());
cpHost.postOperation();
}
});
java.io.IOException