Package org.apache.hadoop.hbase.quotas.policies

Class AbstractViolationPolicyEnforcement

java.lang.Object

org.apache.hadoop.hbase.quotas.policies.AbstractViolationPolicyEnforcement

All Implemented Interfaces:

SpaceViolationPolicyEnforcement

Direct Known Subclasses:

DefaultViolationPolicyEnforcement, MissingSnapshotViolationPolicyEnforcement

@Private
@Evolving
public abstract class AbstractViolationPolicyEnforcement
extends Object
implements SpaceViolationPolicyEnforcement

Abstract implementation for SpaceViolationPolicyEnforcement.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) SpaceQuotaSnapshot	quotaSnapshot
(package private) RegionServerServices	rss
(package private) TableName	tableName

Constructor Summary

Constructors

Constructor	Description
AbstractViolationPolicyEnforcement()

Method Summary

Modifier and Type	Method	Description
boolean	areCompactionsDisabled()	Returns whether or not compactions on this table should be disabled for this policy.
(package private) long	getFileSize(org.apache.hadoop.fs.FileSystem fs, String path)	Computes the size of a single file on the filesystem.
SpaceQuotaSnapshot	getQuotaSnapshot()	Returns the SpaceQuotaSnapshot this was initialized with.
RegionServerServices	getRegionServerServices()
TableName	getTableName()
void	initialize(RegionServerServices rss, TableName tableName, SpaceQuotaSnapshot snapshot)	Initializes this policy instance.
void	setQuotaSnapshot(SpaceQuotaSnapshot snapshot)
void	setRegionServerServices(RegionServerServices rss)
void	setTableName(TableName tableName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement

check, computeBulkLoadSize, disable, enable, getPolicyName, shouldCheckBulkLoads

Field Details

rss

RegionServerServices rss

tableName

TableName tableName

quotaSnapshot

SpaceQuotaSnapshot quotaSnapshot

Constructor Details

AbstractViolationPolicyEnforcement

public AbstractViolationPolicyEnforcement()

Method Details

setRegionServerServices

public void setRegionServerServices(RegionServerServices rss)

setTableName

public void setTableName(TableName tableName)

getRegionServerServices

public RegionServerServices getRegionServerServices()

getTableName

public TableName getTableName()

setQuotaSnapshot

public void setQuotaSnapshot(SpaceQuotaSnapshot snapshot)

getQuotaSnapshot

public SpaceQuotaSnapshot getQuotaSnapshot()

Description copied from interface: SpaceViolationPolicyEnforcement

Returns the SpaceQuotaSnapshot this was initialized with.

Specified by:

getQuotaSnapshot in interface SpaceViolationPolicyEnforcement

initialize

public void initialize(RegionServerServices rss,
 TableName tableName,
 SpaceQuotaSnapshot snapshot)

Description copied from interface: SpaceViolationPolicyEnforcement

Initializes this policy instance.

Specified by:

initialize in interface SpaceViolationPolicyEnforcement

areCompactionsDisabled

public boolean areCompactionsDisabled()

Description copied from interface: SpaceViolationPolicyEnforcement

Returns whether or not compactions on this table should be disabled for this policy.

Specified by:

areCompactionsDisabled in interface SpaceViolationPolicyEnforcement

getFileSize

long getFileSize(org.apache.hadoop.fs.FileSystem fs,
 String path)
          throws SpaceLimitingException

Computes the size of a single file on the filesystem. If the size cannot be computed for some reason, a SpaceLimitingException is thrown, as the file may violate a quota. If the provided path does not reference a file, an IllegalArgumentException is thrown.

Parameters:

fs - The FileSystem which the path refers to a file upon

path - The path on the fs to a file whose size is being checked

Returns:

The size in bytes of the file

Throws:

SpaceLimitingException