public class HFileSystem
extends org.apache.hadoop.fs.FilterFileSystem
Modifier and Type | Field and Description |
---|---|
static String |
HBASE_WAL_DIR
Parameter name for HBase WAL directory
|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
HFileSystem(org.apache.hadoop.conf.Configuration conf,
boolean useHBaseChecksum)
Create a FileSystem object for HBase regionservers.
|
HFileSystem(org.apache.hadoop.fs.FileSystem fs)
Wrap a FileSystem object within a HFileSystem.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
addLocationsOrderInterceptor(org.apache.hadoop.conf.Configuration conf) |
void |
close()
Close this filesystem object
|
org.apache.hadoop.fs.FSDataOutputStream |
createNonRecursive(org.apache.hadoop.fs.Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
org.apache.hadoop.util.Progressable progress)
The org.apache.hadoop.fs.FilterFileSystem does not yet support
createNonRecursive.
|
static org.apache.hadoop.fs.FileSystem |
get(org.apache.hadoop.conf.Configuration conf)
Create a new HFileSystem object, similar to FileSystem.get().
|
org.apache.hadoop.fs.FileSystem |
getBackingFs()
Returns the underlying filesystem
|
static org.apache.hadoop.fs.FileSystem |
getLocalFs(org.apache.hadoop.conf.Configuration conf)
Wrap a LocalFileSystem within a HFileSystem.
|
org.apache.hadoop.fs.FileSystem |
getNoChecksumFs()
Returns the filesystem that is specially setup for
doing reads from storage.
|
boolean |
useHBaseChecksum()
Are we verifying checksums in HBase?
|
access, append, canonicalizeUri, checkPath, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, create, create, createNonRecursive, createSnapshot, createSymlink, delete, deleteSnapshot, getAclStatus, getCanonicalUri, getChildFileSystems, getConf, getDefaultBlockSize, getDefaultBlockSize, getDefaultReplication, getDefaultReplication, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileStatus, getHomeDirectory, getInitialWorkingDirectory, getLinkTarget, getRawFileSystem, getServerDefaults, getServerDefaults, getStatus, getUri, getUsed, getWorkingDirectory, getXAttr, getXAttrs, getXAttrs, initialize, listCorruptFileBlocks, listLocatedStatus, listStatus, listStatusIterator, listXAttrs, makeQualified, mkdirs, modifyAclEntries, open, primitiveCreate, primitiveMkdir, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setOwner, setPermission, setReplication, setTimes, setVerifyChecksum, setWorkingDirectory, setWriteChecksum, setXAttr, setXAttr, startLocalOutput, supportsSymlinks, truncate
addDelegationTokens, append, append, areSymlinksEnabled, cancelDeleteOnExit, clearStatistics, closeAll, closeAllForUGI, copyFromLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createSnapshot, delete, deleteOnExit, enableSymlinks, exists, fixRelativePart, get, get, getAllStatistics, getBlockSize, getCanonicalServiceName, getContentSummary, getDefaultPort, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileSystemClass, getFSofPath, getLength, getLocal, getName, getNamed, getReplication, getScheme, getStatistics, getStatistics, getStatus, globStatus, globStatus, isDirectory, isFile, listFiles, listLocatedStatus, listStatus, listStatus, listStatus, mkdirs, mkdirs, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveMkdir, printStatistics, processDeleteOnExit, setDefaultUri, setDefaultUri
public static final org.apache.commons.logging.Log LOG
public static final String HBASE_WAL_DIR
public HFileSystem(org.apache.hadoop.conf.Configuration conf, boolean useHBaseChecksum) throws 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.IOException
public HFileSystem(org.apache.hadoop.fs.FileSystem fs)
fs
- Set the noChecksumFs and writeFs to this specified filesystem.public org.apache.hadoop.fs.FileSystem getNoChecksumFs()
public org.apache.hadoop.fs.FileSystem getBackingFs() throws IOException
IOException
public boolean useHBaseChecksum()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.hadoop.fs.FilterFileSystem
IOException
public static boolean addLocationsOrderInterceptor(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public static org.apache.hadoop.fs.FileSystem get(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public static org.apache.hadoop.fs.FileSystem getLocalFs(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public org.apache.hadoop.fs.FSDataOutputStream createNonRecursive(org.apache.hadoop.fs.Path f, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress) throws IOException
createNonRecursive
in class org.apache.hadoop.fs.FileSystem
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.