Uses of Interface
org.apache.hadoop.hbase.util.CancelableProgressable

Packages that use CancelableProgressable

Package	Description
org.apache.hadoop.hbase.io.asyncfs
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.regionserver.handler
org.apache.hadoop.hbase.util
org.apache.hadoop.hbase.wal

Uses of CancelableProgressable in org.apache.hadoop.hbase.io.asyncfs

Classes in org.apache.hadoop.hbase.io.asyncfs that implement CancelableProgressable

Modifier and Type	Class and Description
(package private) static class	FanOutOneBlockAsyncDFSOutputHelper.CancelOnClose

Methods in org.apache.hadoop.hbase.io.asyncfs with parameters of type CancelableProgressable

Modifier and Type	Method and Description
void	FanOutOneBlockAsyncDFSOutput.recoverAndClose(CancelableProgressable reporter) The close method when error occurred.
void	AsyncFSOutput.recoverAndClose(CancelableProgressable reporter) The close method when error occurred.
void	WrapperAsyncFSOutput.recoverAndClose(CancelableProgressable reporter)

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

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

Modifier and Type	Method and Description
SplitLogWorker.TaskExecutor.Status	SplitLogWorker.TaskExecutor.exec(String name, CancelableProgressable p)
(package private) long	HRegion.initialize(CancelableProgressable reporter) Initialize this region.
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 void	HRegion.initializeWarmup(CancelableProgressable reporter)
private HRegion	HRegion.openHRegion(CancelableProgressable reporter) Open HRegion.
static HRegion	HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, RegionInfo info, TableDescriptor htd, WAL wal, RegionServerServices rsServices, CancelableProgressable reporter) Open a Region.
static HRegion	HRegion.openHRegion(HRegion other, CancelableProgressable reporter) Useful when reopening a closed region (normally for unit tests)
static HRegion	HRegion.openHRegion(org.apache.hadoop.fs.Path rootDir, RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) Open a Region.
static Region	HRegion.openHRegion(Region other, CancelableProgressable reporter)
static HRegion	HRegion.openHRegion(RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter) Open a Region.
static HRegion	HRegion.openHRegionFromTableDir(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path tableDir, RegionInfo info, TableDescriptor htd, WAL wal, RegionServerServices rsServices, CancelableProgressable reporter) Open a Region.
private long	HRegion.replayRecoveredEdits(org.apache.hadoop.fs.Path edits, Map<byte[],Long> maxSeqIdInStores, CancelableProgressable reporter, org.apache.hadoop.fs.FileSystem fs)
private long	HRegion.replayRecoveredEditsForPaths(long minSeqIdForTheRegion, org.apache.hadoop.fs.FileSystem fs, NavigableSet<org.apache.hadoop.fs.Path> files, CancelableProgressable reporter, org.apache.hadoop.fs.Path regionDir)
(package private) long	HRegion.replayRecoveredEditsIfAny(Map<byte[],Long> maxSeqIdInStores, CancelableProgressable reporter, MonitoredTask status) Read the edits put under this region by wal splitting process.
(package private) static SplitLogWorker.TaskExecutor.Status	SplitLogWorker.splitLog(String filename, CancelableProgressable p, org.apache.hadoop.conf.Configuration conf, RegionServerServices server, LastSequenceId sequenceIdChecker, WALFactory factory) Deprecated. Returns Result either DONE, RESIGNED, or ERR.
static void	HRegion.warmupHRegion(RegionInfo info, TableDescriptor htd, WAL wal, org.apache.hadoop.conf.Configuration conf, RegionServerServices rsServices, CancelableProgressable reporter)

Uses of CancelableProgressable in org.apache.hadoop.hbase.regionserver.handler

Fields in org.apache.hadoop.hbase.regionserver.handler declared as CancelableProgressable

Modifier and Type	Field and Description
private CancelableProgressable	WALSplitterHandler.reporter Deprecated.

Constructors in org.apache.hadoop.hbase.regionserver.handler with parameters of type CancelableProgressable

Constructor and Description
WALSplitterHandler(Server server, SplitLogWorkerCoordination coordination, SplitLogWorkerCoordination.SplitTaskDetails splitDetails, CancelableProgressable reporter, AtomicInteger inProgressTasks, SplitLogWorker.TaskExecutor splitTaskExecutor) Deprecated.

Uses of CancelableProgressable in org.apache.hadoop.hbase.util

Methods in org.apache.hadoop.hbase.util with parameters of type CancelableProgressable

Modifier and Type	Method and Description
private static void	RecoverLeaseFSUtils.checkIfCancelled(CancelableProgressable reporter)
private static boolean	RecoverLeaseFSUtils.recoverDFSFileLease(org.apache.hadoop.hdfs.DistributedFileSystem dfs, org.apache.hadoop.fs.Path p, org.apache.hadoop.conf.Configuration conf, CancelableProgressable reporter)
static void	RecoverLeaseFSUtils.recoverFileLease(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, org.apache.hadoop.conf.Configuration conf, CancelableProgressable reporter) Recover the lease from HDFS, retrying multiple times.

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

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

Modifier and Type	Field and Description
protected CancelableProgressable	OutputSink.reporter

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

Modifier and Type	Method and Description
WAL.Reader	WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, CancelableProgressable reporter) Create a reader for the WAL.
WAL.Reader	WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, CancelableProgressable reporter, boolean allowCustom)
(package private) static WAL.Reader	WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration configuration, CancelableProgressable reporter) Create a reader for the given path, accept custom reader classes from conf.
protected WAL.Reader	WALSplitter.getReader(org.apache.hadoop.fs.FileStatus walStatus, boolean skipErrors, CancelableProgressable cancel) Create a new WAL.Reader for reading logs to split.
private WAL.Reader	WALSplitter.getReader(org.apache.hadoop.fs.Path curLogFile, CancelableProgressable reporter) Create a new WAL.Reader for reading logs to split.
(package private) void	OutputSink.setReporter(CancelableProgressable reporter)
static boolean	WALSplitter.splitLogFile(org.apache.hadoop.fs.Path walDir, org.apache.hadoop.fs.FileStatus logfile, org.apache.hadoop.fs.FileSystem walFS, org.apache.hadoop.conf.Configuration conf, CancelableProgressable reporter, LastSequenceId idChecker, SplitLogWorkerCoordination splitLogWorkerCoordination, WALFactory factory, RegionServerServices rsServices) Splits a WAL file.
(package private) WALSplitter.SplitWALResult	WALSplitter.splitWAL(org.apache.hadoop.fs.FileStatus walStatus, CancelableProgressable cancel) WAL splitting implementation, splits one WAL file.