Package org.apache.hadoop.hbase.quotas
Class RpcThrottlingException
java.lang.Object
java.lang.Throwable
java.lang.Exception
java.io.IOException
org.apache.hadoop.hbase.HBaseIOException
org.apache.hadoop.hbase.quotas.RpcThrottlingException
- All Implemented Interfaces:
Serializable
Describe the throttling result. TODO: At some point this will be handled on the client side to
prevent operation to go on the server if the waitInterval is greater than the one got as result
of this exception.
- See Also:
-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionprivate static final String[]
private static final String
private RpcThrottlingException.Type
private long
-
Constructor Summary
ConstructorDescriptionRpcThrottlingException
(RpcThrottlingException.Type type, long waitInterval, String msg) -
Method Summary
Modifier and TypeMethodDescriptiongetType()
long
protected static String
stringFromMillis
(long millis) static void
throwNumReadRequestsExceeded
(long waitInterval) static void
throwNumRequestsExceeded
(long waitInterval) static void
throwNumWriteRequestsExceeded
(long waitInterval) static void
throwReadCapacityUnitExceeded
(long waitInterval) static void
throwReadSizeExceeded
(long waitInterval) static void
throwRequestCapacityUnitExceeded
(long waitInterval) static void
throwRequestSizeExceeded
(long waitInterval) private static void
throwThrottlingException
(RpcThrottlingException.Type type, long waitInterval) static void
throwWriteCapacityUnitExceeded
(long waitInterval) static void
throwWriteSizeExceeded
(long waitInterval) protected static long
timeFromString
(String timeDiff) Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
Field Details
-
MSG_TYPE
-
MSG_WAIT
- See Also:
-
waitInterval
-
type
-
-
Constructor Details
-
RpcThrottlingException
-
RpcThrottlingException
-
-
Method Details
-
getType
-
getWaitInterval
-
throwNumRequestsExceeded
- Throws:
RpcThrottlingException
-
throwRequestSizeExceeded
- Throws:
RpcThrottlingException
-
throwNumReadRequestsExceeded
- Throws:
RpcThrottlingException
-
throwNumWriteRequestsExceeded
- Throws:
RpcThrottlingException
-
throwWriteSizeExceeded
- Throws:
RpcThrottlingException
-
throwReadSizeExceeded
- Throws:
RpcThrottlingException
-
throwRequestCapacityUnitExceeded
public static void throwRequestCapacityUnitExceeded(long waitInterval) throws RpcThrottlingException - Throws:
RpcThrottlingException
-
throwReadCapacityUnitExceeded
- Throws:
RpcThrottlingException
-
throwWriteCapacityUnitExceeded
- Throws:
RpcThrottlingException
-
throwThrottlingException
private static void throwThrottlingException(RpcThrottlingException.Type type, long waitInterval) throws RpcThrottlingException - Throws:
RpcThrottlingException
-
stringFromMillis
-
timeFromString
-