Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.master.procedure | |
org.apache.hadoop.hbase.procedure2 | |
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Field and Description |
---|---|
private NonceKey |
ProcedureInfo.nonceKey |
Modifier and Type | Method and Description |
---|---|
NonceKey |
ProcedureInfo.getNonceKey() |
Constructor and Description |
---|
ProcedureInfo(long procId,
String procName,
String procOwner,
org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureState procState,
long parentId,
NonceKey nonceKey,
org.apache.hadoop.hbase.protobuf.generated.ErrorHandlingProtos.ForeignExceptionMessage exception,
long lastUpdate,
long startTime,
byte[] result) |
Modifier and Type | Field and Description |
---|---|
private NonceKey |
MasterProcedureUtil.NonceProcedureRunnable.nonceKey |
Modifier and Type | Method and Description |
---|---|
protected NonceKey |
MasterProcedureUtil.NonceProcedureRunnable.getNonceKey() |
Modifier and Type | Field and Description |
---|---|
private NonceKey |
Procedure.nonceKey |
Modifier and Type | Field and Description |
---|---|
private ConcurrentHashMap<NonceKey,Long> |
ProcedureExecutor.nonceKeysToProcIdsMap
Helper map to lookup whether the procedure already issued from the same client.
|
private Map<NonceKey,Long> |
ProcedureExecutor.CompletedProcedureCleaner.nonceKeysToProcIdsMap |
Modifier and Type | Method and Description |
---|---|
NonceKey |
ProcedureExecutor.createNonceKey(long nonceGroup,
long nonce)
Create a NoneKey from the specified nonceGroup and nonce.
|
NonceKey |
Procedure.getNonceKey() |
Modifier and Type | Method and Description |
---|---|
static ProcedureInfo |
Procedure.createProcedureInfo(Procedure proc,
NonceKey nonceKey)
Helper to create the ProcedureInfo from Procedure.
|
long |
ProcedureExecutor.registerNonce(NonceKey nonceKey)
Register a nonce for a procedure that is going to be submitted.
|
void |
ProcedureExecutor.setFailureResultForNonce(NonceKey nonceKey,
String procName,
User procOwner,
IOException exception)
If the failure failed before submitting it, we may want to give back the
same error to the requests with the same nonceKey.
|
protected void |
Procedure.setNonceKey(NonceKey nonceKey)
Called by the ProcedureExecutor to set the value to the newly created procedure.
|
long |
ProcedureExecutor.submitProcedure(Procedure proc,
NonceKey nonceKey)
Add a new root-procedure to the executor.
|
void |
ProcedureExecutor.unregisterNonceIfProcedureWasNotSubmitted(NonceKey nonceKey)
Remove the NonceKey if the procedure was not submitted to the executor.
|
Constructor and Description |
---|
ProcedureExecutor.CompletedProcedureCleaner(org.apache.hadoop.conf.Configuration conf,
ProcedureStore store,
Map<Long,ProcedureInfo> completedMap,
Map<NonceKey,Long> nonceKeysToProcIdsMap) |
Modifier and Type | Field and Description |
---|---|
private ConcurrentHashMap<NonceKey,ServerNonceManager.OperationContext> |
ServerNonceManager.nonces
Nonces.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.