Package org.apache.hadoop.hbase.regionserver.compactions

Class CloseChecker

java.lang.Object

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

@Private
public class CloseChecker
extends Object

Check periodically to see if a system stop is requested

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

CloseChecker

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

Method Details

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.