org.apache.hadoop.hbase.quotas.policies

Class MissingSnapshotViolationPolicyEnforcement

java.lang.Object

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

org.apache.hadoop.hbase.quotas.policies.MissingSnapshotViolationPolicyEnforcement

All Implemented Interfaces:

SpaceViolationPolicyEnforcement

@InterfaceAudience.Private
public final class MissingSnapshotViolationPolicyEnforcement
extends AbstractViolationPolicyEnforcement

A SpaceViolationPolicyEnforcement which can be treated as a singleton. When a quota is not defined on a table or we lack quota information, we want to avoid creating a policy, keeping this path fast.

Field Summary

Fields

Modifier and Type	Field and Description
private static MissingSnapshotViolationPolicyEnforcement	SINGLETON

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

quotaSnapshot, rss, tableName

Constructor Summary

Constructors

Modifier	Constructor and Description
private	MissingSnapshotViolationPolicyEnforcement()

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.
static SpaceViolationPolicyEnforcement	getInstance()
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

Field Detail

SINGLETON

private static final MissingSnapshotViolationPolicyEnforcement SINGLETON

Constructor Detail

MissingSnapshotViolationPolicyEnforcement

private MissingSnapshotViolationPolicyEnforcement()

Method Detail

getInstance

public static SpaceViolationPolicyEnforcement getInstance()

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

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

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.

getPolicyName

public String getPolicyName()

Description copied from interface: SpaceViolationPolicyEnforcement

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