@InterfaceAudience.Private public final class MissingSnapshotViolationPolicyEnforcement extends AbstractViolationPolicyEnforcement
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.Modifier and Type | Field and Description |
---|---|
private static MissingSnapshotViolationPolicyEnforcement |
SINGLETON |
quotaSnapshot, rss, tableName
Modifier | Constructor and Description |
---|---|
private |
MissingSnapshotViolationPolicyEnforcement() |
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 . |
areCompactionsDisabled, getFileSize, getQuotaSnapshot, getRegionServerServices, getTableName, initialize, setQuotaSnapshot, setRegionServerServices, setTableName
private static final MissingSnapshotViolationPolicyEnforcement SINGLETON
private MissingSnapshotViolationPolicyEnforcement()
public static SpaceViolationPolicyEnforcement getInstance()
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
public void enable() throws IOException
SpaceViolationPolicyEnforcement
IOException
public void disable() throws IOException
SpaceViolationPolicyEnforcement
IOException
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 String getPolicyName()
SpaceViolationPolicyEnforcement
SpaceViolationPolicy
that this enforcement is for.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.