public static final class TestMigrateReplicationQueueFromZkToTableProcedure.FakePeerProcedure extends org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> implements org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
Constructor and Description |
---|
FakePeerProcedure() |
FakePeerProcedure(String peerId) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
abort(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) |
protected org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>[] |
execute(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
String |
getPeerId() |
org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType |
getPeerOperationType() |
protected void |
rollback(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) |
protected void |
serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) |
acquireLock, addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doExecute, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcedureMetrics, getProcId, getProcIdHashCode, getProcName, getResult, getRootProcedureId, getRootProcId, getStackIndexes, getState, getSubmittedTime, getTimeout, getTimeoutTimestamp, hasChildren, hasException, hasLock, hasOwner, hasParent, hasTimeout, haveSameParent, holdLock, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, isYieldAfterExecutionStep, releaseLock, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, suspend, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, toStringState, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted
public FakePeerProcedure()
public FakePeerProcedure(String peerId)
public String getPeerId()
getPeerId
in interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
public org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType getPeerOperationType()
getPeerOperationType
in interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
protected org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>[] execute(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws org.apache.hadoop.hbase.procedure2.ProcedureYieldException, org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException, InterruptedException
execute
in class org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
org.apache.hadoop.hbase.procedure2.ProcedureYieldException
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
InterruptedException
protected void rollback(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) throws IOException, InterruptedException
rollback
in class org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
IOException
InterruptedException
protected boolean abort(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
abort
in class org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
protected void serializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException
serializeStateData
in class org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
IOException
protected void deserializeStateData(org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer serializer) throws IOException
deserializeStateData
in class org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.