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:

BulkLoadCheckingViolationPolicyEnforcement, DisableTableViolationPolicyEnforcement, NoInsertsViolationPolicyEnforcement, NoWritesViolationPolicyEnforcement

public abstract class AbstractViolationPolicyEnforcement
extends Object
implements SpaceViolationPolicyEnforcement

Abstract implementation for SpaceViolationPolicyEnforcement.

Constructor Summary

Constructors

Constructor and Description
AbstractViolationPolicyEnforcement()

Method Summary

Modifier and Type	Method and Description
boolean	areCompactionsDisabled() Returns whether or not compactions on this table should be disabled for this policy.
void	checkBulkLoad(FileSystem fs, List<String> paths) Checks the file at the given path against this policy and the current SpaceQuotaSnapshot.
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)
boolean	shouldCheckBulkLoads() Returns whether the caller should verify any bulk loads against this.

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, disable, enable, getPolicyName

Constructor Detail

AbstractViolationPolicyEnforcement

public AbstractViolationPolicyEnforcement()

Method Detail

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

shouldCheckBulkLoads

public boolean shouldCheckBulkLoads()

Description copied from interface: SpaceViolationPolicyEnforcement

Returns whether the caller should verify any bulk loads against this.

Specified by:

shouldCheckBulkLoads in interface SpaceViolationPolicyEnforcement

checkBulkLoad

public void checkBulkLoad(FileSystem fs,
                          List<String> paths)
                   throws SpaceLimitingException

Description copied from interface: SpaceViolationPolicyEnforcement

Checks the file at the given path against this policy and the current SpaceQuotaSnapshot. If the file would violate the policy, a SpaceLimitingException will be thrown.

Specified by:

checkBulkLoad in interface SpaceViolationPolicyEnforcement

paths - The paths in HDFS to files to be bulk loaded.

Throws:

SpaceLimitingException