org.apache.hadoop.hbase.regionserver

Class LogRoller

java.lang.Object

HasThread

org.apache.hadoop.hbase.regionserver.LogRoller

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class LogRoller
extends HasThread
implements java.io.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 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()

run

public void run()

walRollFinished

public boolean walRollFinished()

For testing only

Returns:

true if all WAL roll finished

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable