@InterfaceAudience.Private public class FlushTableSubprocedure extends Subprocedure
Modifier and Type | Class and Description |
---|---|
private static class |
FlushTableSubprocedure.RegionFlushTask |
Subprocedure.SubprocedureImpl
Modifier and Type | Field and Description |
---|---|
private String |
family |
private static org.slf4j.Logger |
LOG |
private List<HRegion> |
regions |
private String |
table |
private RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool |
taskManager |
executionTimeoutTimer, monitor, rpcs, wakeFrequency
Constructor and Description |
---|
FlushTableSubprocedure(ProcedureMember member,
ForeignExceptionDispatcher errorListener,
long wakeFrequency,
long timeout,
List<HRegion> regions,
String table,
String family,
RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager) |
Modifier and Type | Method and Description |
---|---|
void |
acquireBarrier()
Flush the online regions on this rs for the target table.
|
void |
cleanup(Exception e)
Cancel threads if they haven't finished.
|
private void |
flushRegions() |
byte[] |
insideBarrier()
The implementation of this method should act with the assumption that the barrier condition has
been satisfied.
|
void |
releaseBarrier() |
call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted
private static final org.slf4j.Logger LOG
private final RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager
public FlushTableSubprocedure(ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, List<HRegion> regions, String table, String family, RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager)
private void flushRegions() throws ForeignException
ForeignException
public void acquireBarrier() throws ForeignException
acquireBarrier
in class Subprocedure
ForeignException
public byte[] insideBarrier() throws ForeignException
Subprocedure
insideBarrier
in class Subprocedure
ForeignException
public void cleanup(Exception e)
cleanup
in class Subprocedure
public void releaseBarrier()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.