@InterfaceAudience.Private public class DefaultViolationPolicyEnforcement extends AbstractViolationPolicyEnforcement
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.quotaSnapshot, rss, tableName
Constructor and Description |
---|
DefaultViolationPolicyEnforcement() |
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 . |
areCompactionsDisabled, getFileSize, getQuotaSnapshot, getRegionServerServices, getTableName, initialize, setQuotaSnapshot, setRegionServerServices, setTableName
public DefaultViolationPolicyEnforcement()
public void enable() throws IOException
SpaceViolationPolicyEnforcement
IOException
public void disable() throws IOException
SpaceViolationPolicyEnforcement
IOException
public String getPolicyName()
SpaceViolationPolicyEnforcement
SpaceViolationPolicy
that this enforcement is for.public void check(Mutation m) throws SpaceLimitingException
SpaceViolationPolicyEnforcement
Mutation
against this
policy. If the Mutation
violates the policy, this policy should throw a SpaceLimitingException
.SpaceLimitingException
- When the given mutation violates this policy.public boolean shouldCheckBulkLoads()
SpaceViolationPolicyEnforcement
this
.public long computeBulkLoadSize(org.apache.hadoop.fs.FileSystem fs, List<String> paths) throws SpaceLimitingException
SpaceViolationPolicyEnforcement
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.SpaceLimitingException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.