Uses of Interface
org.apache.hadoop.hbase.monitoring.MonitoredTask

Packages that use MonitoredTask

Package	Description
org.apache.hadoop.hbase.master
org.apache.hadoop.hbase.master.procedure
org.apache.hadoop.hbase.master.snapshot
org.apache.hadoop.hbase.mob
org.apache.hadoop.hbase.monitoring
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.snapshot
org.apache.hadoop.hbase.wal

Uses of MonitoredTask in org.apache.hadoop.hbase.master

Methods in org.apache.hadoop.hbase.master with parameters of type MonitoredTask

Modifier and Type	Method and Description
(package private) boolean	ActiveMasterManager.blockUntilBecomingActiveMaster(int checkInterval, MonitoredTask startupStatus) Block until becoming the active master.
private void	HMaster.finishActiveMasterInitialization(MonitoredTask status) Finish initialization of HMaster after becoming the primary master.
private void	HMaster.waitForRegionServers(MonitoredTask status)
void	ServerManager.waitForRegionServers(MonitoredTask status) Wait for the region servers to report in.
private void	SplitLogManager.waitForSplittingCompletion(SplitLogManager.TaskBatch batch, MonitoredTask status)

Uses of MonitoredTask in org.apache.hadoop.hbase.master.procedure

Fields in org.apache.hadoop.hbase.master.procedure declared as MonitoredTask

Modifier and Type	Field and Description
private MonitoredTask	CloneSnapshotProcedure.monitorStatus
private MonitoredTask	RestoreSnapshotProcedure.monitorStatus

Methods in org.apache.hadoop.hbase.master.procedure that return MonitoredTask

Modifier and Type	Method and Description
private MonitoredTask	CloneSnapshotProcedure.getMonitorStatus() Set up monitor status if it is not created.
private MonitoredTask	RestoreSnapshotProcedure.getMonitorStatus() Set up monitor status if it is not created.

Uses of MonitoredTask in org.apache.hadoop.hbase.master.snapshot

Fields in org.apache.hadoop.hbase.master.snapshot declared as MonitoredTask

Modifier and Type	Field and Description
protected MonitoredTask	TakeSnapshotHandler.status

Uses of MonitoredTask in org.apache.hadoop.hbase.mob

Methods in org.apache.hadoop.hbase.mob with parameters of type MonitoredTask

Modifier and Type	Method and Description
List<org.apache.hadoop.fs.Path>	DefaultMobStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker) Flushes the snapshot of the MemStore.
protected void	DefaultMobStoreFlusher.performMobFlush(MemStoreSnapshot snapshot, long cacheFlushId, InternalScanner scanner, StoreFileWriter writer, MonitoredTask status, ThroughputController throughputController) Flushes the cells in the mob store.

Uses of MonitoredTask in org.apache.hadoop.hbase.monitoring

Subinterfaces of MonitoredTask in org.apache.hadoop.hbase.monitoring

Modifier and Type	Interface and Description
interface	MonitoredRPCHandler A MonitoredTask implementation optimized for use with RPC Handlers handling frequent, short duration tasks.

Classes in org.apache.hadoop.hbase.monitoring that implement MonitoredTask

Modifier and Type	Class and Description
class	MonitoredRPCHandlerImpl A MonitoredTask implementation designed for use with RPC Handlers handling frequent, short duration tasks.
(package private) class	MonitoredTaskImpl

Fields in org.apache.hadoop.hbase.monitoring declared as MonitoredTask

Modifier and Type	Field and Description
private MonitoredTask	TaskMonitor.TaskAndWeakRefPair.impl

Fields in org.apache.hadoop.hbase.monitoring with type parameters of type MonitoredTask

Modifier and Type	Field and Description
private WeakReference<MonitoredTask>	TaskMonitor.TaskAndWeakRefPair.weakProxy

Methods in org.apache.hadoop.hbase.monitoring that return MonitoredTask

Modifier and Type	Method and Description
MonitoredTask	MonitoredTask.clone() Public exposure of Object.clone() in order to allow clients to easily capture current state.
MonitoredTask	TaskMonitor.createStatus(String description)
MonitoredTask	TaskMonitor.TaskAndWeakRefPair.get()

Methods in org.apache.hadoop.hbase.monitoring that return types with arguments of type MonitoredTask

Modifier and Type	Method and Description
List<MonitoredTask>	TaskMonitor.getTasks() Produces a list containing copies of the current state of all non-expired MonitoredTasks handled by this TaskMonitor.
List<MonitoredTask>	TaskMonitor.getTasks(String filter) Produces a list containing copies of the current state of all non-expired MonitoredTasks handled by this TaskMonitor.

Methods in org.apache.hadoop.hbase.monitoring with parameters of type MonitoredTask

Modifier and Type	Method and Description
private boolean	TaskMonitor.canPurge(MonitoredTask stat)
boolean	TaskMonitor.TaskFilter.filter(MonitoredTask task) Filter out unwanted task.

Method parameters in org.apache.hadoop.hbase.monitoring with type arguments of type MonitoredTask

Modifier and Type	Method and Description
private static void	TaskMonitor.processTasks(Iterable<TaskMonitor.TaskAndWeakRefPair> tasks, TaskMonitor.TaskFilter filter, List<MonitoredTask> results)

Constructors in org.apache.hadoop.hbase.monitoring with parameters of type MonitoredTask

Constructor and Description
TaskAndWeakRefPair(MonitoredTask stat, MonitoredTask proxy)

Uses of MonitoredTask in org.apache.hadoop.hbase.regionserver

Methods in org.apache.hadoop.hbase.regionserver with parameters of type MonitoredTask

Modifier and Type	Method and Description
boolean	HStore.StoreFlusherImpl.commit(MonitoredTask status)
boolean	StoreFlushContext.commit(MonitoredTask status) Commit the flush - add the store file to the store and clear the memstore snapshot.
private HStoreFile	HStore.commitFile(org.apache.hadoop.fs.Path path, long logCacheFlushId, MonitoredTask status)
private Map<byte[],List<HStoreFile>>	HRegion.doClose(boolean abort, MonitoredTask status)
protected void	StoreFlusher.finalizeWriter(StoreFileWriter writer, long cacheFlushSeqNum, MonitoredTask status)
protected List<org.apache.hadoop.fs.Path>	HStore.flushCache(long logCacheFlushId, MemStoreSnapshot snapshot, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker) Write out current snapshot.
void	HStore.StoreFlusherImpl.flushCache(MonitoredTask status)
void	StoreFlushContext.flushCache(MonitoredTask status) Flush the cache (create the new store file) A length operation which doesn't require locking out any function of the store.
List<org.apache.hadoop.fs.Path>	DefaultStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker)
abstract List<org.apache.hadoop.fs.Path>	StoreFlusher.flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushSeqNum, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker) Turns a snapshot of memstore into a set of store files.
List<org.apache.hadoop.fs.Path>	StripeStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushSeqNum, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker)
private long	HRegion.initializeRegionInternals(CancelableProgressable reporter, MonitoredTask status)
private long	HRegion.initializeStores(CancelableProgressable reporter, MonitoredTask status) Open all Stores.
private HRegion.FlushResultImpl	HRegion.internalFlushcache(Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker) Flushing given stores.
private HRegion.FlushResult	HRegion.internalFlushcache(MonitoredTask status) Flushing all stores.
protected HRegion.FlushResultImpl	HRegion.internalFlushcache(WAL wal, long myseqid, Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker) Flush the memstore.
protected HRegion.FlushResultImpl	HRegion.internalFlushCacheAndCommit(WAL wal, MonitoredTask status, HRegion.PrepareFlushResult prepareResult, Collection<HStore> storesToFlush)
protected HRegion.PrepareFlushResult	HRegion.internalPrepareFlushCache(WAL wal, long myseqid, Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker)
protected long	HRegion.replayRecoveredEditsIfAny(Map<byte[],Long> maxSeqIdInStores, CancelableProgressable reporter, MonitoredTask status) Read the edits put under this region by wal splitting process.

Uses of MonitoredTask in org.apache.hadoop.hbase.snapshot

Fields in org.apache.hadoop.hbase.snapshot declared as MonitoredTask

Modifier and Type	Field and Description
private MonitoredTask	RestoreSnapshotHelper.status

Constructors in org.apache.hadoop.hbase.snapshot with parameters of type MonitoredTask

Constructor and Description
RestoreSnapshotHelper(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, SnapshotManifest manifest, TableDescriptor tableDescriptor, org.apache.hadoop.fs.Path rootDir, ForeignExceptionDispatcher monitor, MonitoredTask status)
RestoreSnapshotHelper(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, SnapshotManifest manifest, TableDescriptor tableDescriptor, org.apache.hadoop.fs.Path rootDir, ForeignExceptionDispatcher monitor, MonitoredTask status, boolean createBackRefs)

Uses of MonitoredTask in org.apache.hadoop.hbase.wal

Fields in org.apache.hadoop.hbase.wal declared as MonitoredTask

Modifier and Type	Field and Description
private MonitoredTask	WALSplitter.status