@InterfaceAudience.Private public final class ProcedureUtil extends Object
Modifier and Type | Class and Description |
---|---|
private static class |
ProcedureUtil.CompatStateSerializer
A serializer (deserializer) for those Procedures which were serialized
before this patch.
|
private static class |
ProcedureUtil.StateSerializer
A serializer for our Procedures.
|
Modifier | Constructor and Description |
---|---|
private |
ProcedureUtil() |
Modifier and Type | Method and Description |
---|---|
static Procedure<?> |
convertToProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proto)
Helper to convert the protobuf procedure.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockedResource |
convertToProtoLockedResource(LockedResource lockedResource) |
static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockType |
convertToProtoLockType(LockType lockType) |
static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure |
convertToProtoProcedure(Procedure<?> proc)
Helper to convert the procedure to protobuf.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockedResourceType |
convertToProtoResourceType(LockedResourceType resourceType) |
static long |
getBackoffTimeMs(int attempts)
Get an exponential backoff time, in milliseconds.
|
private static Procedure<?> |
newProcedure(String className) |
(package private) static void |
validateClass(Procedure<?> proc) |
private ProcedureUtil()
private static Procedure<?> newProcedure(String className) throws BadProcedureException
BadProcedureException
static void validateClass(Procedure<?> proc) throws BadProcedureException
BadProcedureException
public static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure convertToProtoProcedure(Procedure<?> proc) throws IOException
Used by ProcedureStore implementations.
IOException
public static Procedure<?> convertToProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proto) throws IOException
Used by ProcedureStore implementations.
TODO: OPTIMIZATION: some of the field never change during the execution (e.g. className, procId, parentId, ...). We can split in 'data' and 'state', and the store may take advantage of it by storing the data only on insert().
IOException
public static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockedResourceType convertToProtoResourceType(LockedResourceType resourceType)
public static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockType convertToProtoLockType(LockType lockType)
public static org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockedResource convertToProtoLockedResource(LockedResource lockedResource) throws IOException
IOException
public static long getBackoffTimeMs(int attempts)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.