org.apache.hadoop.hbase.master.region

Class MasterRegionWALRoller

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.wal.AbstractWALRoller<Abortable>

org.apache.hadoop.hbase.master.region.MasterRegionWALRoller

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

@InterfaceAudience.Private
public final class MasterRegionWALRoller
extends AbstractWALRoller<Abortable>

As long as there is no RegionServerServices for a master local region, we need implement log roller logic by our own.

We can reuse most of the code for normal wal roller, the only difference is that there is only one region, so in scheduleFlush(String) method we can just schedule flush for the master local region.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private String	archivedWALSuffix
private MasterRegionFlusherAndCompactor	flusherAndCompactor
private org.apache.hadoop.fs.FileSystem	fs
private org.apache.hadoop.fs.Path	globalWALArchiveDir
private static org.slf4j.Logger	LOG
private org.apache.hadoop.fs.Path	walArchiveDir

Fields inherited from class org.apache.hadoop.hbase.wal.AbstractWALRoller

abortable, WAL_ROLL_PERIOD_KEY, walNeedsRoll

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
private	MasterRegionWALRoller(String name, org.apache.hadoop.conf.Configuration conf, Abortable abortable, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path walRootDir, org.apache.hadoop.fs.Path globalWALRootDir, String archivedWALSuffix)

Method Summary

Modifier and Type	Method and Description
protected void	afterRoll(WAL wal) Called after we finish rolling the give wal.
(package private) static MasterRegionWALRoller	create(String name, org.apache.hadoop.conf.Configuration conf, Abortable abortable, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path walRootDir, org.apache.hadoop.fs.Path globalWALRootDir, String archivedWALSuffix, long rollPeriodMs, long flushSize)
protected void	scheduleFlush(String encodedRegionName)
(package private) void	setFlusherAndCompactor(MasterRegionFlusherAndCompactor flusherAndCompactor)

Methods inherited from class org.apache.hadoop.hbase.wal.AbstractWALRoller

addWAL, close, requestRollAll, run, waitUntilWalRollFinished, walRollFinished

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

flusherAndCompactor

private volatile MasterRegionFlusherAndCompactor flusherAndCompactor

fs

private final org.apache.hadoop.fs.FileSystem fs

walArchiveDir

private final org.apache.hadoop.fs.Path walArchiveDir

globalWALArchiveDir

private final org.apache.hadoop.fs.Path globalWALArchiveDir

archivedWALSuffix

private final String archivedWALSuffix

Constructor Detail

MasterRegionWALRoller

private MasterRegionWALRoller(String name,
                              org.apache.hadoop.conf.Configuration conf,
                              Abortable abortable,
                              org.apache.hadoop.fs.FileSystem fs,
                              org.apache.hadoop.fs.Path walRootDir,
                              org.apache.hadoop.fs.Path globalWALRootDir,
                              String archivedWALSuffix)

Method Detail

afterRoll

protected void afterRoll(WAL wal)

Description copied from class: AbstractWALRoller

Called after we finish rolling the give wal.

Overrides:

afterRoll in class AbstractWALRoller<Abortable>

scheduleFlush

protected void scheduleFlush(String encodedRegionName)

Specified by:

scheduleFlush in class AbstractWALRoller<Abortable>

Parameters:

encodedRegionName - Encoded name of region to flush.

setFlusherAndCompactor

void setFlusherAndCompactor(MasterRegionFlusherAndCompactor flusherAndCompactor)

create

static MasterRegionWALRoller create(String name,
                                    org.apache.hadoop.conf.Configuration conf,
                                    Abortable abortable,
                                    org.apache.hadoop.fs.FileSystem fs,
                                    org.apache.hadoop.fs.Path walRootDir,
                                    org.apache.hadoop.fs.Path globalWALRootDir,
                                    String archivedWALSuffix,
                                    long rollPeriodMs,
                                    long flushSize)