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	Description
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)	Deprecated.

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	Description
private MonitoredTask	CloneSnapshotProcedure.monitorStatus
private MonitoredTask	RestoreSnapshotProcedure.monitorStatus
private MonitoredTask	ServerCrashProcedure.status
private MonitoredTask	SnapshotProcedure.status

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

Modifier and Type	Method	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	Description
protected final 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	Description
protected void	DefaultMobStoreFlusher.finalizeWriter(StoreFileWriter writer, long cacheFlushSeqNum, MonitoredTask status)
List<org.apache.hadoop.fs.Path>	DefaultMobStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)	Flushes the snapshot of the MemStore.
protected void	DefaultMobStoreFlusher.performMobFlush(MemStoreSnapshot snapshot, long cacheFlushId, InternalScanner scanner, StoreFileWriter writer, MonitoredTask status, ThroughputController throughputController, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)	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	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	Description
class	MonitoredRPCHandlerImpl	A MonitoredTask implementation designed for use with RPC Handlers handling frequent, short duration tasks.
(package private) class	MonitoredTaskImpl
class	TaskGroup	The TaskGroup can be seen as a big MonitoredTask, which contains a list of sub monitored tasks.

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

Modifier and Type	Field	Description
private final MonitoredTask	TaskGroup.delegate	Used to track this task group in TaskMonitor
private MonitoredTask	TaskMonitor.TaskAndWeakRefPair.impl

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

Modifier and Type	Field	Description
private final ConcurrentLinkedDeque<MonitoredTask>	TaskGroup.tasks	Sub-tasks in the group
private WeakReference<MonitoredTask>	TaskMonitor.TaskAndWeakRefPair.weakProxy

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

Modifier and Type	Method	Description
MonitoredTask	TaskGroup.addTask(String description)
MonitoredTask	TaskGroup.addTask(String description, boolean withCompleteLast)	Add a new task to the group, and before that might complete the last task in the group
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.createStatus(String description, boolean ignore)
MonitoredTask	TaskMonitor.createStatus(String description, boolean ignore, boolean enableJournal)	Create a monitored task for users to inquire about the status
MonitoredTask	TaskMonitor.TaskAndWeakRefPair.get()

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

Modifier and Type	Method	Description
Collection<MonitoredTask>	TaskGroup.getTasks()
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	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	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

Modifier	Constructor	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	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 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, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)	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, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
abstract List<org.apache.hadoop.fs.Path>	StoreFlusher.flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushSeqNum, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)	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, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
private long	HRegion.initializeRegionInternals(CancelableProgressable reporter, MonitoredTask status)
private long	HRegion.initializeStores(CancelableProgressable reporter, MonitoredTask status)	Open all Stores.
private long	HRegion.initializeStores(CancelableProgressable reporter, MonitoredTask status, boolean warmup)
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.
(package private) 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)
(package private) 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	Description
private final MonitoredTask	RestoreSnapshotHelper.status
private final MonitoredTask	SnapshotManifest.statusTask

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

Modifier and Type	Method	Description
static SnapshotManifest	SnapshotManifest.create(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path workingDir, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription desc, ForeignExceptionSnare monitor, MonitoredTask statusTask)

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

Modifier	Constructor	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)
private	SnapshotManifest(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem rootFs, org.apache.hadoop.fs.Path workingDir, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription desc, ForeignExceptionSnare monitor, MonitoredTask statusTask)

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

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

Modifier and Type	Field	Description
protected MonitoredTask	OutputSink.status

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

Modifier and Type	Method	Description
(package private) void	OutputSink.setStatus(MonitoredTask status)