Package org.apache.hadoop.hbase.master.procedure

Class MasterProcedureUtil

java.lang.Object

org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil

@Private
@Evolving
public final class MasterProcedureUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MasterProcedureUtil.NonceProcedureRunnable	Helper Runnable used in conjunction with submitProcedure() to deal with submitting procs with nonce.
static interface	MasterProcedureUtil.RSGroupGetter

Field Summary

Fields

Modifier and Type	Field	Description
private static final Pattern	PATTERN	Deprecated. Since 2.3.0, will be removed in 4.0.0.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MasterProcedureUtil()

Method Summary

Modifier and Type	Method	Description
static RSGroupInfo	checkGroupExists(MasterProcedureUtil.RSGroupGetter getter, Optional<String> optGroupName, Supplier<String> forWhom)
static void	checkGroupNotEmpty(RSGroupInfo rsGroupInfo, Supplier<String> forWhom)	Do not allow creating new tables/namespaces which has an empty rs group, expect the default rs group.
static Optional<String>	getNamespaceGroup(NamespaceDescriptor namespaceDesc)
static int	getServerPriority(ServerProcedureInterface proc)	Return the priority for the given procedure.
static int	getTablePriority(TableName tableName)	Return the priority for the given table.
static long	submitProcedure(MasterProcedureUtil.NonceProcedureRunnable runnable)	Helper used to deal with submitting procs with nonce.
static org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	toProtoUserInfo(User user)
static User	toUserInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation userInfoProto)
static IOException	unwrapRemoteIOException(Procedure<?> proc)	This is a version of unwrapRemoteIOException that can do DoNotRetryIOE.
static boolean	validateProcedureWALFilename(String filename)	A Procedure WAL file name is of the format: pv-<wal-id>.log where wal-id is 20 digits.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PATTERN

@Deprecated
private static final Pattern PATTERN

Deprecated.

Since 2.3.0, will be removed in 4.0.0. We do not use this style of procedure wal file name any more.

Pattern used to validate a Procedure WAL file name see validateProcedureWALFilename(String) for description.

Constructor Details

MasterProcedureUtil

private MasterProcedureUtil()

Method Details

toProtoUserInfo

public static org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation toProtoUserInfo(User user)

toUserInfo

public static User toUserInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation userInfoProto)

submitProcedure

public static long submitProcedure(MasterProcedureUtil.NonceProcedureRunnable runnable)
                            throws IOException

Helper used to deal with submitting procs with nonce. Internally the NonceProcedureRunnable.run() will be called only if no one else registered the nonce. any Exception thrown by the run() method will be collected/handled and rethrown. long procId = MasterProcedureUtil.submitProcedure( new NonceProcedureRunnable(procExec, nonceGroup, nonce) { @Override public void run() { cpHost.preOperation(); submitProcedure(new MyProc()); cpHost.postOperation(); } });

Throws:

IOException

validateProcedureWALFilename

public static boolean validateProcedureWALFilename(String filename)

A Procedure WAL file name is of the format: pv-<wal-id>.log where wal-id is 20 digits.

Parameters:

filename - name of the file to validate

Returns:

true if the filename matches a Procedure WAL, false otherwise

getTablePriority

public static int getTablePriority(TableName tableName)

Return the priority for the given table. Now meta table is 3, other system tables are 2, and user tables are 1.

getServerPriority

public static int getServerPriority(ServerProcedureInterface proc)

Return the priority for the given procedure. For now we only have two priorities, 100 for server carrying meta, and 1 for others.

unwrapRemoteIOException

public static IOException unwrapRemoteIOException(Procedure<?> proc)

This is a version of unwrapRemoteIOException that can do DoNotRetryIOE. We need to throw DNRIOE to clients if a failed Procedure else they will keep trying. The default proc.getException().unwrapRemoteException doesn't have access to DNRIOE from the procedure2 module.

checkGroupNotEmpty

public static void checkGroupNotEmpty(RSGroupInfo rsGroupInfo,
 Supplier<String> forWhom)
                               throws ConstraintException

Do not allow creating new tables/namespaces which has an empty rs group, expect the default rs group. Notice that we do not check for online servers, as this is not stable because region servers can die at any time.

Throws:

ConstraintException

checkGroupExists

public static RSGroupInfo checkGroupExists(MasterProcedureUtil.RSGroupGetter getter,
 Optional<String> optGroupName,
 Supplier<String> forWhom)
                                    throws IOException

Throws:

IOException

getNamespaceGroup

public static Optional<String> getNamespaceGroup(NamespaceDescriptor namespaceDesc)