public class HFileSystem
extends FilterFileSystem
Modifier and Type | Field and Description |
---|---|
static Logger |
LOG |
Constructor and Description |
---|
HFileSystem(Configuration conf,
boolean useHBaseChecksum)
Create a FileSystem object for HBase regionservers.
|
HFileSystem(FileSystem fs)
Wrap a FileSystem object within a HFileSystem.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
addLocationsOrderInterceptor(Configuration conf) |
void |
close()
Close this filesystem object
|
FSDataOutputStream |
createNonRecursive(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
The org.apache.hadoop.fs.FilterFileSystem does not yet support
createNonRecursive.
|
static FileSystem |
get(Configuration conf)
Create a new HFileSystem object, similar to FileSystem.get().
|
FileSystem |
getBackingFs()
Returns the underlying filesystem
|
static FileSystem |
getLocalFs(Configuration conf)
Wrap a LocalFileSystem within a HFileSystem.
|
FileSystem |
getNoChecksumFs()
Returns the filesystem that is specially setup for
doing reads from storage.
|
java.lang.String |
getStoragePolicyName(Path path)
Get the storage policy of the source path (directory/file).
|
void |
setStoragePolicy(Path path,
java.lang.String policyName)
Set the source path (directory/file) to the specified storage policy.
|
boolean |
useHBaseChecksum()
Are we verifying checksums in HBase?
|
public HFileSystem(Configuration conf, boolean useHBaseChecksum) throws java.io.IOException
conf
- The configuration to be used for the filesystemuseHBaseChecksum
- if true, then use
checksum verfication in hbase, otherwise
delegate checksum verification to the FileSystem.java.io.IOException
public HFileSystem(FileSystem fs)
fs
- Set the noChecksumFs and writeFs to this specified filesystem.public FileSystem getNoChecksumFs()
public FileSystem getBackingFs() throws java.io.IOException
java.io.IOException
public void setStoragePolicy(Path path, java.lang.String policyName)
path
- The source path (directory/file).policyName
- The name of the storage policy: 'HOT', 'COLD', etc.
See see hadoop 2.6+ org.apache.hadoop.hdfs.protocol.HdfsConstants for possible list e.g
'COLD', 'WARM', 'HOT', 'ONE_SSD', 'ALL_SSD', 'LAZY_PERSIST'.public java.lang.String getStoragePolicyName(Path path)
path
- The source path (directory/file).null
if not using DistributedFileSystem
or
exception thrown when trying to get policypublic boolean useHBaseChecksum()
public void close() throws java.io.IOException
java.io.IOException
public static boolean addLocationsOrderInterceptor(Configuration conf) throws java.io.IOException
java.io.IOException
public static FileSystem get(Configuration conf) throws java.io.IOException
java.io.IOException
public static FileSystem getLocalFs(Configuration conf) throws java.io.IOException
java.io.IOException
public FSDataOutputStream createNonRecursive(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws java.io.IOException
java.io.IOException