org.apache.hadoop.hbase.regionserver

Class LogRoller

java.lang.Object

java.lang.Thread

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

org.apache.hadoop.hbase.regionserver.LogRoller

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

@InterfaceAudience.Private
public class LogRoller
extends AbstractWALRoller<RegionServerServices>

Runs periodically to determine if the WAL should be rolled. NOTE: This class extends Thread rather than Chore because the sleep time can be interrupted when there is something to do, rather than the Chore sleep time which is invariant. TODO: change to a pool of threads

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.wal.AbstractWALRoller

AbstractWALRoller.RollController

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

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

abortable, DEFAULT_WAL_ROLL_WAIT_TIMEOUT, WAL_ROLL_PERIOD_KEY, WAL_ROLL_RETRIES, WAL_ROLL_WAIT_TIMEOUT, wals

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
LogRoller(RegionServerServices services)

Method Summary

Modifier and Type	Method and Description
(package private) Map<WAL,AbstractWALRoller.RollController>	getWalNeedsRoll()
protected void	scheduleFlush(String encodedRegionName, List<byte[]> families)

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

addWAL, afterWALArchive, 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

Constructor Detail

LogRoller

public LogRoller(RegionServerServices services)

Method Detail

scheduleFlush

protected void scheduleFlush(String encodedRegionName,
                             List<byte[]> families)

Specified by:

scheduleFlush in class AbstractWALRoller<RegionServerServices>

Parameters:

encodedRegionName - Encoded name of region to flush.

families - stores of region to flush.

getWalNeedsRoll

Map<WAL,AbstractWALRoller.RollController> getWalNeedsRoll()