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
private long	addSingleFile(org.apache.hadoop.fs.FileSystem fs, String path)
void	check(Mutation m) Checks the given Mutation against this policy.
void	checkBulkLoad(org.apache.hadoop.fs.FileSystem fs, List<String> paths) Checks the file 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, 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.

checkBulkLoad

public void checkBulkLoad(org.apache.hadoop.fs.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.

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

Throws:

SpaceLimitingException

addSingleFile

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

Throws:

SpaceLimitingException