org.apache.hadoop.hbase.quotas.policies

Class DefaultViolationPolicyEnforcement

java.lang.Object

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

org.apache.hadoop.hbase.quotas.policies.DefaultViolationPolicyEnforcement

All Implemented Interfaces:

SpaceViolationPolicyEnforcement

Direct Known Subclasses:

DisableTableViolationPolicyEnforcement, NoInsertsViolationPolicyEnforcement, NoWritesViolationPolicyEnforcement

@InterfaceAudience.Private
public class DefaultViolationPolicyEnforcement
extends AbstractViolationPolicyEnforcement

The default implementation for SpaceViolationPolicyEnforcement. This is done because all tables, whether or not they're in violation now, should be checking bulk loads to proactively catch a swell of files that would push the table into violation.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.quotas.policies.AbstractViolationPolicyEnforcement

quotaSnapshot, rss, tableName

Constructor Summary

Constructors

Constructor and Description
DefaultViolationPolicyEnforcement()

Method Summary

Modifier and Type	Method and Description
void	check(Mutation m) Checks the given Mutation against this policy.
long	computeBulkLoadSize(org.apache.hadoop.fs.FileSystem fs, List<String> paths) Computes the size of the file(s) at the given path against this policy and the current SpaceQuotaSnapshot.
void	disable() Disables this policy.
void	enable() Enables this policy.
String	getPolicyName() Returns a logical name for the SpaceViolationPolicy that this enforcement is for.
boolean	shouldCheckBulkLoads() Returns whether thet caller should verify any bulk loads against this.

Methods inherited from class org.apache.hadoop.hbase.quotas.policies.AbstractViolationPolicyEnforcement

areCompactionsDisabled, getFileSize, getQuotaSnapshot, getRegionServerServices, getTableName, initialize, setQuotaSnapshot, setRegionServerServices, setTableName

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultViolationPolicyEnforcement

public DefaultViolationPolicyEnforcement()

Method Detail

enable

public void enable()
            throws IOException

Description copied from interface: SpaceViolationPolicyEnforcement

Enables this policy. Not all policies have enable actions.

Throws:

IOException

disable

public void disable()
             throws IOException

Description copied from interface: SpaceViolationPolicyEnforcement

Disables this policy. Not all policies have disable actions.

Throws:

IOException

getPolicyName

public String getPolicyName()

Description copied from interface: SpaceViolationPolicyEnforcement

Returns a logical name for the SpaceViolationPolicy that this enforcement is for.

check

public void check(Mutation m)
           throws SpaceLimitingException

Description copied from interface: SpaceViolationPolicyEnforcement

Checks the given Mutation against this policy. If the Mutation violates the policy, this policy should throw a SpaceLimitingException.

Throws:

SpaceLimitingException - When the given mutation violates this policy.

shouldCheckBulkLoads

public boolean shouldCheckBulkLoads()

Description copied from interface: SpaceViolationPolicyEnforcement

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

computeBulkLoadSize

public long computeBulkLoadSize(org.apache.hadoop.fs.FileSystem fs,
                                List<String> paths)
                         throws SpaceLimitingException

Description copied from interface: SpaceViolationPolicyEnforcement

Computes the size of the file(s) at the given path against this policy and the current SpaceQuotaSnapshot. If the file would violate the policy, a SpaceLimitingException will be thrown.

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

Returns:

The size, in bytes, of the files that would be loaded.

Throws:

SpaceLimitingException