@InterfaceAudience.Private public final class ErasureCodingUtils extends Object
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
Modifier | Constructor and Description |
---|---|
private |
ErasureCodingUtils() |
Modifier and Type | Method and Description |
---|---|
private static void |
checkAvailable(org.apache.hadoop.hdfs.DistributedFileSystem dfs,
String policy) |
private static org.apache.hadoop.fs.Path |
createTempDir(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tempDir) |
private static org.apache.hadoop.hdfs.DistributedFileSystem |
getDfs(org.apache.hadoop.conf.Configuration conf) |
private static org.apache.hadoop.hdfs.DistributedFileSystem |
getDfs(org.apache.hadoop.fs.FileSystem fs) |
static boolean |
needsSync(TableDescriptor oldDescriptor,
TableDescriptor newDescriptor)
Check if EC policy is different between two descriptors
|
static void |
setPolicy(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
String policy)
Sets the EC policy on the path
|
static void |
setPolicy(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
TableName tableName,
String policy)
Sets the EC policy on the table directory for the specified table
|
static void |
sync(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
TableDescriptor newDescriptor)
Sync the EC policy state from the newDescriptor onto the FS for the table dir of the provided
table descriptor.
|
static void |
unsetPolicy(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
TableName tableName)
Unsets any EC policy specified on the path.
|
static void |
verifySupport(org.apache.hadoop.conf.Configuration conf,
String policy)
Runs checks against the FileSystem, verifying that HDFS is supported and the policy is
available, enabled, and works with a simple write.
|
private static final org.slf4j.Logger LOG
private ErasureCodingUtils()
public static void verifySupport(org.apache.hadoop.conf.Configuration conf, String policy) throws HBaseIOException
HBaseIOException
private static org.apache.hadoop.fs.Path createTempDir(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path tempDir) throws HBaseIOException
HBaseIOException
private static void checkAvailable(org.apache.hadoop.hdfs.DistributedFileSystem dfs, String policy) throws HBaseIOException
HBaseIOException
public static boolean needsSync(TableDescriptor oldDescriptor, TableDescriptor newDescriptor)
public static void sync(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, TableDescriptor newDescriptor) throws IOException
newDescriptor
- descriptor containing the policy and table nameIOException
public static void setPolicy(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, TableName tableName, String policy) throws IOException
IOException
public static void setPolicy(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, String policy) throws IOException
IOException
public static void unsetPolicy(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, TableName tableName) throws IOException
IOException
private static org.apache.hadoop.hdfs.DistributedFileSystem getDfs(org.apache.hadoop.conf.Configuration conf) throws HBaseIOException
HBaseIOException
private static org.apache.hadoop.hdfs.DistributedFileSystem getDfs(org.apache.hadoop.fs.FileSystem fs) throws DoNotRetryIOException
DoNotRetryIOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.