Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id B9699200C4E for ; Thu, 6 Apr 2017 22:01:10 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id B82F3160B81; Thu, 6 Apr 2017 20:01:10 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id A7D2C160BAA for ; Thu, 6 Apr 2017 22:01:08 +0200 (CEST) Received: (qmail 38254 invoked by uid 500); 6 Apr 2017 20:01:05 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 35936 invoked by uid 99); 6 Apr 2017 20:01:04 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Apr 2017 20:01:04 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 21832F49E5; Thu, 6 Apr 2017 20:01:03 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: git-site-role@apache.org To: commits@hbase.apache.org Date: Thu, 06 Apr 2017 20:01:23 -0000 Message-Id: <10c1857c49e148a6a97b554082301682@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [22/25] hbase-site git commit: Published site at 9109803891e256f8c047af72572f07695e604a3f. archived-at: Thu, 06 Apr 2017 20:01:10 -0000 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ddcd3ebf/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html index 4da9cb6..b119ecc 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.StoppableThread.html @@ -126,7 +126,7 @@ var activeTableTab = "activeTableTab";

-
private abstract static class ProcedureExecutor.StoppableThread
+
private abstract static class ProcedureExecutor.StoppableThread
 extends Thread
@@ -237,7 +237,7 @@ extends
  • StoppableThread

    -
    public StoppableThread(ThreadGroup group,
    +
    public StoppableThread(ThreadGroup group,
                            String name)
  • @@ -255,7 +255,7 @@ extends
  • sendStopSignal

    -
    public abstract void sendStopSignal()
    +
    public abstract void sendStopSignal()
  • @@ -264,7 +264,7 @@ extends
  • awaitTermination

    -
    public void awaitTermination()
    +
    public void awaitTermination()
  • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ddcd3ebf/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html index dba60c3..0bb19cf 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.TimeoutExecutorThread.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab";

    -
    private final class ProcedureExecutor.TimeoutExecutorThread
    +
    private final class ProcedureExecutor.TimeoutExecutorThread
     extends ProcedureExecutor.StoppableThread
    @@ -283,7 +283,7 @@ extends
  • queue

    -
    private final DelayQueue<DelayedUtil.DelayedWithTimeout> queue
    +
    private final DelayQueue<DelayedUtil.DelayedWithTimeout> queue
  • @@ -300,7 +300,7 @@ extends
  • TimeoutExecutorThread

    -
    public TimeoutExecutorThread(ThreadGroup group)
    +
    public TimeoutExecutorThread(ThreadGroup group)
  • @@ -317,7 +317,7 @@ extends
  • sendStopSignal

    -
    public void sendStopSignal()
    +
    public void sendStopSignal()
    Specified by:
    sendStopSignal in class ProcedureExecutor.StoppableThread
    @@ -330,7 +330,7 @@ extends
  • run

    -
    public void run()
    +
    public void run()
    Specified by:
    run in interface Runnable
    @@ -345,7 +345,7 @@ extends
  • add

    -
    public void add(ProcedureExecutor.InlineChore chore)
    +
    public void add(ProcedureExecutor.InlineChore chore)
  • @@ -354,7 +354,7 @@ extends
  • add

    -
    public void add(Procedure procedure)
    +
    public void add(Procedure procedure)
  • @@ -363,7 +363,7 @@ extends
  • remove

    -
    public boolean remove(Procedure procedure)
    +
    public boolean remove(Procedure procedure)
  • @@ -372,7 +372,7 @@ extends
  • execInlineChore

    -
    private void execInlineChore(ProcedureExecutor.InlineChore chore)
    +
    private void execInlineChore(ProcedureExecutor.InlineChore chore)
  • @@ -381,7 +381,7 @@ extends
  • execDelayedProcedure

    -
    private void execDelayedProcedure(ProcedureExecutor.DelayedProcedure delayed)
    +
    private void execDelayedProcedure(ProcedureExecutor.DelayedProcedure delayed)
  • @@ -390,7 +390,7 @@ extends
  • executeInMemoryChore

    -
    private void executeInMemoryChore(ProcedureInMemoryChore chore)
    +
    private void executeInMemoryChore(ProcedureInMemoryChore chore)
  • @@ -399,7 +399,7 @@ extends
  • executeTimedoutProcedure

    -
    private void executeTimedoutProcedure(Procedure proc)
    +
    private void executeTimedoutProcedure(Procedure proc)
  • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ddcd3ebf/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html index 9150a67..2f28a93 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerMonitor.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab";


    -
    private final class ProcedureExecutor.WorkerMonitor
    +
    private final class ProcedureExecutor.WorkerMonitor
     extends ProcedureExecutor.InlineChore
  • @@ -277,7 +277,7 @@ extends
  • WORKER_MONITOR_INTERVAL_CONF_KEY

    -
    public static final String WORKER_MONITOR_INTERVAL_CONF_KEY
    +
    public static final String WORKER_MONITOR_INTERVAL_CONF_KEY
    See Also:
    Constant Field Values
    @@ -290,7 +290,7 @@ extends
  • DEFAULT_WORKER_MONITOR_INTERVAL

    -
    private static final int DEFAULT_WORKER_MONITOR_INTERVAL
    +
    private static final int DEFAULT_WORKER_MONITOR_INTERVAL
    See Also:
    Constant Field Values
    @@ -303,7 +303,7 @@ extends
  • WORKER_STUCK_THRESHOLD_CONF_KEY

    -
    public static final String WORKER_STUCK_THRESHOLD_CONF_KEY
    +
    public static final String WORKER_STUCK_THRESHOLD_CONF_KEY
    See Also:
    Constant Field Values
    @@ -316,7 +316,7 @@ extends
  • DEFAULT_WORKER_STUCK_THRESHOLD

    -
    private static final int DEFAULT_WORKER_STUCK_THRESHOLD
    +
    private static final int DEFAULT_WORKER_STUCK_THRESHOLD
    See Also:
    Constant Field Values
    @@ -329,7 +329,7 @@ extends
  • WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY

    -
    public static final String WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY
    +
    public static final String WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY
    See Also:
    Constant Field Values
    @@ -342,7 +342,7 @@ extends
  • DEFAULT_WORKER_ADD_STUCK_PERCENTAGE

    -
    private static final float DEFAULT_WORKER_ADD_STUCK_PERCENTAGE
    +
    private static final float DEFAULT_WORKER_ADD_STUCK_PERCENTAGE
    See Also:
    Constant Field Values
    @@ -355,7 +355,7 @@ extends
  • addWorkerStuckPercentage

    -
    private float addWorkerStuckPercentage
    +
    private float addWorkerStuckPercentage
  • @@ -364,7 +364,7 @@ extends
  • timeoutInterval

    -
    private int timeoutInterval
    +
    private int timeoutInterval
  • @@ -373,7 +373,7 @@ extends
  • stuckThreshold

    -
    private int stuckThreshold
    +
    private int stuckThreshold
  • @@ -390,7 +390,7 @@ extends
  • WorkerMonitor

    -
    public WorkerMonitor()
    +
    public WorkerMonitor()
  • @@ -407,7 +407,7 @@ extends
  • run

    -
    public void run()
    +
    public void run()
  • @@ -416,7 +416,7 @@ extends
  • checkForStuckWorkers

    -
    private int checkForStuckWorkers()
    +
    private int checkForStuckWorkers()
  • @@ -425,7 +425,7 @@ extends
  • checkThreadCount

    -
    private void checkThreadCount(int stuckCount)
    +
    private void checkThreadCount(int stuckCount)
  • @@ -434,7 +434,7 @@ extends
  • refreshConfig

    -
    private void refreshConfig()
    +
    private void refreshConfig()
  • @@ -443,7 +443,7 @@ extends
  • getTimeoutInterval

    -
    public int getTimeoutInterval()
    +
    public int getTimeoutInterval()
    Specified by:
    getTimeoutInterval in class ProcedureExecutor.InlineChore
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ddcd3ebf/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html index 79a515a..779d23c 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.WorkerThread.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab";


    -
    private final class ProcedureExecutor.WorkerThread
    +
    private final class ProcedureExecutor.WorkerThread
     extends ProcedureExecutor.StoppableThread
  • @@ -263,7 +263,7 @@ extends
  • executionStartTime

    -
    private final AtomicLong executionStartTime
    +
    private final AtomicLong executionStartTime
  • @@ -280,7 +280,7 @@ extends
  • WorkerThread

    -
    public WorkerThread(ThreadGroup group)
    +
    public WorkerThread(ThreadGroup group)
  • @@ -297,7 +297,7 @@ extends
  • sendStopSignal

    -
    public void sendStopSignal()
    +
    public void sendStopSignal()
    Specified by:
    sendStopSignal in class ProcedureExecutor.StoppableThread
    @@ -310,7 +310,7 @@ extends
  • run

    -
    public void run()
    +
    public void run()
    Specified by:
    run in interface Runnable
    @@ -325,7 +325,7 @@ extends
  • getCurrentRunTime

    -
    public long getCurrentRunTime()
    +
    public long getCurrentRunTime()
    Returns:
    the time since the current procedure is running
    @@ -338,7 +338,7 @@ extends
  • keepAlive

    -
    private boolean keepAlive(long lastUpdate)
    +
    private boolean keepAlive(long lastUpdate)
  • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ddcd3ebf/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html index c1f1373..01d5913 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.html @@ -996,7 +996,7 @@ extends
  • start

    -
    public void start(int numThreads,
    +
    public void start(int numThreads,
                       boolean abortOnCorruption)
                throws IOException
    Start the procedure executor. @@ -1019,7 +1019,7 @@ extends
  • stop

    -
    public void stop()
    +
    public void stop()
  • @@ -1028,7 +1028,7 @@ extends
  • join

    -
    public void join()
    +
    public void join()
  • @@ -1037,7 +1037,7 @@ extends
  • refreshConfiguration

    -
    public void refreshConfiguration(org.apache.hadoop.conf.Configuration conf)
    +
    public void refreshConfiguration(org.apache.hadoop.conf.Configuration conf)
  • @@ -1046,7 +1046,7 @@ extends
  • isRunning

    -
    public boolean isRunning()
    +
    public boolean isRunning()
  • @@ -1055,7 +1055,7 @@ extends
  • getWorkerThreadCount

    -
    public int getWorkerThreadCount()
    +
    public int getWorkerThreadCount()
    Returns:
    the current number of worker threads.
    @@ -1068,7 +1068,7 @@ extends
  • getCorePoolSize

    -
    public int getCorePoolSize()
    +
    public int getCorePoolSize()
    Returns:
    the core pool size settings.
    @@ -1081,7 +1081,7 @@ extends
  • getActiveExecutorCount

    -
    public int getActiveExecutorCount()
    +
    public int getActiveExecutorCount()
  • @@ -1090,7 +1090,7 @@ extends
  • getEnvironment

    -
    public TEnvironment getEnvironment()
    +
    public TEnvironment getEnvironment()
  • @@ -1099,7 +1099,7 @@ extends
  • getStore

    -
    public ProcedureStore getStore()
    +
    public ProcedureStore getStore()
  • @@ -1108,7 +1108,7 @@ extends
  • getScheduler

    -
    protected ProcedureScheduler getScheduler()
    +
    protected ProcedureScheduler getScheduler()
  • @@ -1117,7 +1117,7 @@ extends
  • setKeepAliveTime

    -
    public void setKeepAliveTime(long keepAliveTime,
    +
    public void setKeepAliveTime(long keepAliveTime,
                                  TimeUnit timeUnit)
  • @@ -1127,7 +1127,7 @@ extends
  • getKeepAliveTime

    -
    public long getKeepAliveTime(TimeUnit timeUnit)
    +
    public long getKeepAliveTime(TimeUnit timeUnit)
  • @@ -1136,7 +1136,7 @@ extends
  • addChore

    -
    public void addChore(ProcedureInMemoryChore chore)
    +
    public void addChore(ProcedureInMemoryChore chore)
    Add a chore procedure to the executor
    Parameters:
    @@ -1150,7 +1150,7 @@ extends
  • removeChore

    -
    public boolean removeChore(ProcedureInMemoryChore chore)
    +
    public boolean removeChore(ProcedureInMemoryChore chore)
    Remove a chore procedure from the executor
    Parameters:
    @@ -1166,7 +1166,7 @@ extends
  • createNonceKey

    -
    public NonceKey createNonceKey(long nonceGroup,
    +
    public NonceKey createNonceKey(long nonceGroup,
                                    long nonce)
    Create a NoneKey from the specified nonceGroup and nonce.
    @@ -1184,7 +1184,7 @@ extends
  • registerNonce

    -
    public long registerNonce(NonceKey nonceKey)
    +
    public long registerNonce(NonceKey nonceKey)
    Register a nonce for a procedure that is going to be submitted. A procId will be reserved and on submitProcedure(), the procedure with the specified nonce will take the reserved ProcId. @@ -1205,7 +1205,7 @@ extends
  • unregisterNonceIfProcedureWasNotSubmitted

    -
    public void unregisterNonceIfProcedureWasNotSubmitted(NonceKey nonceKey)
    +
    public void unregisterNonceIfProcedureWasNotSubmitted(NonceKey nonceKey)
    Remove the NonceKey if the procedure was not submitted to the executor.
    Parameters:
    @@ -1219,7 +1219,7 @@ extends
  • setFailureResultForNonce

    -
    public void setFailureResultForNonce(NonceKey nonceKey,
    +
    public void setFailureResultForNonce(NonceKey nonceKey,
                                          String procName,
                                          User procOwner,
                                          IOException exception)
    @@ -1240,7 +1240,7 @@ extends
  • submitProcedure

    -
    public long submitProcedure(Procedure proc)
    +
    public long submitProcedure(Procedure proc)
    Add a new root-procedure to the executor.
    Parameters:
    @@ -1256,7 +1256,7 @@ extends
  • submitProcedure

    -
    public long submitProcedure(Procedure proc,
    +
    public long submitProcedure(Procedure proc,
                                 NonceKey nonceKey)
    Add a new root-procedure to the executor.
    @@ -1274,7 +1274,7 @@ extends
  • submitProcedures

    -
    public void submitProcedures(Procedure[] procs)
    +
    public void submitProcedures(Procedure[] procs)
    Add a set of new root-procedure to the executor.
    Parameters:
    @@ -1288,7 +1288,7 @@ extends
  • prepareProcedure

    -
    private Procedure prepareProcedure(Procedure proc)
    +
    private Procedure prepareProcedure(Procedure proc)
  • @@ -1297,7 +1297,7 @@ extends
  • pushProcedure

    -
    private long pushProcedure(Procedure proc)
    +
    private long pushProcedure(Procedure proc)
  • @@ -1306,7 +1306,7 @@ extends
  • abort

    -
    public boolean abort(long procId)
    +
    public boolean abort(long procId)
    Send an abort notification the specified procedure. Depending on the procedure implementation the abort can be considered or ignored.
    @@ -1323,7 +1323,7 @@ extends
  • abort

    -
    public boolean abort(long procId,
    +
    public boolean abort(long procId,
                          boolean mayInterruptIfRunning)
    Send an abort notification the specified procedure. Depending on the procedure implementation the abort can be considered or ignored.
    @@ -1342,7 +1342,7 @@ extends
  • getProcedure

    -
    public Procedure getProcedure(long procId)
    +
    public Procedure getProcedure(long procId)
  • @@ -1351,7 +1351,7 @@ extends
  • getProcedure

    -
    public <T extends Procedure> T getProcedure(Class<T> clazz,
    +
    public <T extends Procedure> T getProcedure(Class<T> clazz,
                                                 long procId)
  • @@ -1361,7 +1361,7 @@ extends
  • getResult

    -
    public ProcedureInfo getResult(long procId)
    +
    public ProcedureInfo getResult(long procId)
  • @@ -1370,7 +1370,7 @@ extends
  • isFinished

    -
    public boolean isFinished(long procId)
    +
    public boolean isFinished(long procId)
    Return true if the procedure is finished. The state may be "completed successfully" or "failed and rolledback". Use getResult() to check the state or get the result data.
    @@ -1388,7 +1388,7 @@ extends
  • isStarted

    -
    public boolean isStarted(long procId)
    +
    public boolean isStarted(long procId)
    Return true if the procedure is started.
    Parameters:
    @@ -1404,7 +1404,7 @@ extends
  • removeResult

    -
    public void removeResult(long procId)
    +
    public void removeResult(long procId)
    Mark the specified completed procedure, as ready to remove.
    Parameters:
    @@ -1418,7 +1418,7 @@ extends
  • getResultOrProcedure

    -
    public Pair<ProcedureInfo,ProceduregetResultOrProcedure(long procId)
    +
    public Pair<ProcedureInfo,ProceduregetResultOrProcedure(long procId)
  • @@ -1427,7 +1427,7 @@ extends
  • isProcedureOwner

    -
    public boolean isProcedureOwner(long procId,
    +
    public boolean isProcedureOwner(long procId,
                                     User user)
    Check if the user is this procedure's owner
    @@ -1446,7 +1446,7 @@ extends
  • listProcedures

    -
    public List<ProcedureInfolistProcedures()
    +
    public List<ProcedureInfolistProcedures()
    List procedures.
    Returns:
    @@ -1460,7 +1460,7 @@ extends
  • registerListener

    -
    public void registerListener(ProcedureExecutor.ProcedureExecutorListener listener)
    +
    public void registerListener(ProcedureExecutor.ProcedureExecutorListener listener)
  • @@ -1469,7 +1469,7 @@ extends
  • unregisterListener

    -
    public boolean unregisterListener(ProcedureExecutor.ProcedureExecutorListener listener)
    +
    public boolean unregisterListener(ProcedureExecutor.ProcedureExecutorListener listener)
  • @@ -1478,7 +1478,7 @@ extends
  • sendProcedureLoadedNotification

    -
    private void sendProcedureLoadedNotification(long procId)
    +
    private void sendProcedureLoadedNotification(long procId)
  • @@ -1487,7 +1487,7 @@ extends
  • sendProcedureAddedNotification

    -
    private void sendProcedureAddedNotification(long procId)
    +
    private void sendProcedureAddedNotification(long procId)
  • @@ -1496,7 +1496,7 @@ extends
  • sendProcedureFinishedNotification

    -
    private void sendProcedureFinishedNotification(long procId)
    +
    private void sendProcedureFinishedNotification(long procId)
  • @@ -1505,7 +1505,7 @@ extends
  • nextProcId

    -
    private long nextProcId()
    +
    private long nextProcId()
  • @@ -1514,7 +1514,7 @@ extends
  • getLastProcId

    -
    protected long getLastProcId()
    +
    protected long getLastProcId()
  • @@ -1523,7 +1523,7 @@ extends
  • getActiveProcIds

    -
    public Set<LonggetActiveProcIds()
    +
    public Set<LonggetActiveProcIds()
  • @@ -1532,7 +1532,7 @@ extends
  • getRootProcedureId

    -
    private Long getRootProcedureId(Procedure proc)
    +
    private Long getRootProcedureId(Procedure proc)
  • @@ -1541,7 +1541,7 @@ extends
  • executeProcedure

    -
    private void executeProcedure(Procedure proc)
    +
    private void executeProcedure(Procedure proc)
  • @@ -1550,7 +1550,7 @@ extends
  • acquireLock

    -
    private Procedure.LockState acquireLock(Procedure proc)
    +
    private Procedure.LockState acquireLock(Procedure proc)
  • @@ -1559,7 +1559,7 @@ extends
  • releaseLock

    -
    private void releaseLock(Procedure proc,
    +
    private void releaseLock(Procedure proc,
                              boolean force)
  • @@ -1569,7 +1569,7 @@ extends
  • executeRollback

    -
    private Procedure.LockState executeRollback(long rootProcId,
    +
    private Procedure.LockState executeRollback(long rootProcId,
                                                 RootProcedureState procStack)
    Execute the rollback of the full procedure stack. Once the procedure is rolledback, the root-procedure will be visible as @@ -1582,7 +1582,7 @@ extends
  • executeRollback

    -
    private Procedure.LockState executeRollback(Procedure proc)
    +
    private Procedure.LockState executeRollback(Procedure proc)
    Execute the rollback of the procedure step. It updates the store with the new state (stack index) or will remove completly the procedure in case it is a child.
    @@ -1594,7 +1594,7 @@ extends
  • execProcedure

    -
    private void execProcedure(RootProcedureState procStack,
    +
    private void execProcedure(RootProcedureState procStack,
                                Procedure procedure)
  • http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ddcd3ebf/devapidocs/org/apache/hadoop/hbase/procedure2/StateMachineProcedure.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/StateMachineProcedure.html b/devapidocs/org/apache/hadoop/hbase/procedure2/StateMachineProcedure.html index eb9a012..0bb404e 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/StateMachineProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/StateMachineProcedure.html @@ -319,7 +319,7 @@ extends protected boolean isYieldAfterExecutionStep(TEnvironment env) -
    By default, the executor will try ro run procedures start to finish.
    +
    By default, the executor will try to run procedures start to finish.
    @@ -754,9 +754,9 @@ extends isYieldAfterExecutionStep(TEnvironment env)
    Description copied from class: Procedure
    -
    By default, the executor will try ro run procedures start to finish. +
    By default, the executor will try to run procedures start to finish. Return true to make the executor yield between each execution step to - give other procedures time to run their steps.
    + give other procedures a chance to run.
    Overrides:
    isYieldAfterExecutionStep in class Procedure<TEnvironment>