org.apache.hadoop.hbase.regionserver

Class LogRoller

java.lang.Object

org.apache.hadoop.hbase.util.HasThread

org.apache.hadoop.hbase.regionserver.LogRoller

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

@InterfaceAudience.Private
public class LogRoller
extends HasThread
implements Closeable

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

Field Summary

Fields

Modifier and Type	Field and Description
protected RegionServerServices	services

Constructor Summary

Constructors

Constructor and Description
LogRoller(Server server, RegionServerServices services)

Method Summary

Modifier and Type	Method and Description
void	addWAL(WAL wal)
void	close()
void	interrupt()
void	requestRollAll()
void	run()
boolean	walRollFinished() For testing only

Methods inherited from class org.apache.hadoop.hbase.util.HasThread

getName, getThread, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start

Methods inherited from class java.lang.Object

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

Field Detail

services

protected final RegionServerServices services

Constructor Detail

LogRoller

public LogRoller(Server server,
                 RegionServerServices services)

Parameters:

server -

Method Detail

addWAL

public void addWAL(WAL wal)

requestRollAll

public void requestRollAll()

interrupt

public void interrupt()

Overrides:

interrupt in class HasThread

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class HasThread

walRollFinished

public boolean walRollFinished()

For testing only

Returns:

true if all WAL roll finished

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable