org.apache.hadoop.hbase.regionserver.compactions

Class CloseChecker

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.CloseChecker

@InterfaceAudience.Private
public class CloseChecker
extends Object

Check periodically to see if a system stop is requested

Field Summary

Fields

Modifier and Type	Field and Description
private long	bytesWrittenProgressForCloseCheck
private int	closeCheckSizeLimit
private long	closeCheckTimeLimit
private long	lastCloseCheckMillis
static String	SIZE_LIMIT_KEY
static String	TIME_LIMIT_KEY

Constructor Summary

Constructors

Constructor and Description
CloseChecker(org.apache.hadoop.conf.Configuration conf, long currentTime)

Method Summary

Modifier and Type	Method and Description
boolean	isSizeLimit(Store store, long bytesWritten) Check periodically to see if a system stop is requested every written bytes reach size limit.
boolean	isTimeLimit(Store store, long now) Check periodically to see if a system stop is requested every time.

Methods inherited from class java.lang.Object

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

Field Detail

SIZE_LIMIT_KEY

public static final String SIZE_LIMIT_KEY

See Also:

Constant Field Values

TIME_LIMIT_KEY

public static final String TIME_LIMIT_KEY

See Also:

Constant Field Values

closeCheckSizeLimit

private final int closeCheckSizeLimit

closeCheckTimeLimit

private final long closeCheckTimeLimit

bytesWrittenProgressForCloseCheck

private long bytesWrittenProgressForCloseCheck

lastCloseCheckMillis

private long lastCloseCheckMillis

Constructor Detail

CloseChecker

public CloseChecker(org.apache.hadoop.conf.Configuration conf,
                    long currentTime)

Method Detail

isSizeLimit

public boolean isSizeLimit(Store store,
                           long bytesWritten)

Check periodically to see if a system stop is requested every written bytes reach size limit.

Returns:

if true, system stop.

isTimeLimit

public boolean isTimeLimit(Store store,
                           long now)

Check periodically to see if a system stop is requested every time.

Returns:

if true, system stop.