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
private long	checkLowReplicationInterval
private long	lastRollTime
private static org.slf4j.Logger	LOG
private long	rollPeriod
private boolean	running
private Server	server
protected RegionServerServices	services
private int	threadWakeFrequency
private ConcurrentMap<WAL,Boolean>	walNeedsRoll

Constructor Summary

Constructors

Constructor and Description
LogRoller(Server server, RegionServerServices services)

Method Summary

Modifier and Type	Method and Description
private void	abort(String reason, Throwable cause)
void	addWAL(WAL wal)
private void	checkLowReplication(long now) we need to check low replication in period, see HBASE-18132
void	close()
void	requestRollAll()
void	run()
private void	scheduleFlush(String encodedRegionName)
boolean	walRollFinished() For testing only

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

getName, getThread, interrupt, 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

LOG

private static final org.slf4j.Logger LOG

walNeedsRoll

private final ConcurrentMap<WAL,Boolean> walNeedsRoll

server

private final Server server

services

protected final RegionServerServices services

lastRollTime

private volatile long lastRollTime

rollPeriod

private final long rollPeriod

threadWakeFrequency

private final int threadWakeFrequency

checkLowReplicationInterval

private long checkLowReplicationInterval

running

private volatile boolean running

Constructor Detail

LogRoller

public LogRoller(Server server,
                 RegionServerServices services)

Parameters:

server -

Method Detail

addWAL

public void addWAL(WAL wal)

requestRollAll

public void requestRollAll()

checkLowReplication

private void checkLowReplication(long now)

we need to check low replication in period, see HBASE-18132

abort

private void abort(String reason,
                   Throwable cause)

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class HasThread

scheduleFlush

private void scheduleFlush(String encodedRegionName)

Parameters:

encodedRegionName - Encoded name of region to flush.

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