public class MapRFileSystem
extends org.apache.hadoop.fs.FileSystem
implements com.mapr.fs.jni.MapRConstants
DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics
AtimeBit, AuditBit, ChunkSizeBit, ClusterConfDefault, CompressBit, CompressorTypeBit, DEFAULT_USER_IDENTIFIER, DEFAULT_USER_IDENTIFIER_ESCAPED, DefaultChunkSize, DefaultCLDBIp, DefaultCLDBPort, EMPTY_BYTE_ARRAY, EMPTY_END_ROW, EMPTY_START_ROW, FidNameBit, GroupBit, HADOOP_SECURITY_SPOOFED_GID, HADOOP_SECURITY_SPOOFED_GROUP, HADOOP_SECURITY_SPOOFED_UID, HADOOP_SECURITY_SPOOFED_USER, HOSTNAME_IP_SEPARATOR, IP_PORT_SEPARATOR, LAST_ROW, LATEST_TIMESTAMP, MAPR_ENV_VAR, MAPR_PROPERTY_HOME, MapRClusterDir, MapRClusterDirPattern, MapRClusterDirSlash, MAPRFS_PREFIX, MAPRFS_SCHEME, MapRHomeDefault, MAX_CLUSTERS_CROSSED, MAX_PATH_LENGTH, MAX_PORT_NUMBER, MAX_RA_THREADS, MIN_RA_THREADS, MinChunkSize, ModeBit, MtimeBit, MULTI_ADDR_SEPARATOR, NUM_CONTAINERS_PER_RPC, OLDEST_TIMESTAMP, ReplBit, UserBit, UTF8_ENCODING, WireSecureBit
Constructor and Description |
---|
MapRFileSystem() |
Modifier and Type | Method and Description |
---|---|
byte[] |
getXAttr(org.apache.hadoop.fs.Path path,
java.lang.String name)
Get the extended attribute associated with the given name on the given file
or directory.
|
java.util.Map<java.lang.String,byte[]> |
getXAttrs(org.apache.hadoop.fs.Path path)
Get all the extended attribute name/value pairs associated with the
given file or directory.
|
java.util.Map<java.lang.String,byte[]> |
getXAttrs(org.apache.hadoop.fs.Path path,
java.util.List<java.lang.String> names)
Get the extended attributes associated with the given list of names on
the given file or directory.
|
java.util.List<java.lang.String> |
listXAttrs(org.apache.hadoop.fs.Path path)
Get all the extended attribute names associated with the given file or
directory.
|
void |
removeXAttr(org.apache.hadoop.fs.Path path,
java.lang.String name)
Remove the extended attribute (specified by name) associated with the
given file or directory.
|
void |
setXAttr(org.apache.hadoop.fs.Path path,
java.lang.String name,
byte[] value)
Set or replace an extended attribute on a file or directory.
|
void |
setXAttr(org.apache.hadoop.fs.Path path,
java.lang.String name,
byte[] value,
java.util.EnumSet<org.apache.hadoop.fs.XAttrSetFlag> flag)
Set an extended attribute on a file or directory.
|
access, addDelegationTokens, append, append, append, areSymlinksEnabled, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, close, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, create, create, createFid, createNewFile, createNonRecursive, createNonRecursive, createNonRecursive, createPathId, createSnapshot, createSnapshot, createSymlink, delete, delete, deleteFid, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getBlockSize, getCanonicalServiceName, getCanonicalUri, getChildFileSystems, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileStatus, getFileSystemClass, getFSofPath, getHomeDirectory, getInitialWorkingDirectory, getJobTrackerAddrs, getLength, getLinkTarget, getLocal, getName, getNamed, getReplication, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getUri, getUsed, getWorkingDirectory, getZkConnectString, globStatus, globStatus, initialize, isDirectory, isFile, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatus, listStatusIterator, makeQualified, mkdirs, mkdirs, mkdirs, mkdirsFid, mkdirsFid, modifyAclEntries, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, open, openFid, openFid, openFid2, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, rename, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setOwner, setOwnerFid, setPermission, setReplication, setTimes, setVerifyChecksum, setWorkingDirectory, setWriteChecksum, startLocalOutput, supportsSymlinks, truncate
public void setXAttr(org.apache.hadoop.fs.Path path, java.lang.String name, byte[] value, java.util.EnumSet<org.apache.hadoop.fs.XAttrSetFlag> flag) throws java.io.IOException
setXAttr
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.name
- The extended attribute name. This must be prefixed with the
namespace followed by ".". For example, "user.attr".value
- The extended attribute value.flag
- The java.io.IOException
public void setXAttr(org.apache.hadoop.fs.Path path, java.lang.String name, byte[] value) throws java.io.IOException
setXAttr
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.name
- The extended attribute name. This must be prefixed with the
namespace followed by ".". For example, "user.attr".value
- The extended attribute value.java.io.IOException
public byte[] getXAttr(org.apache.hadoop.fs.Path path, java.lang.String name) throws java.io.IOException
getXAttr
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.name
- The name of the extended attribute (to retrieve). The name must be
prefixed with the namespace followed by ".". For example, "user.attr".java.io.IOException
public java.util.Map<java.lang.String,byte[]> getXAttrs(org.apache.hadoop.fs.Path path) throws java.io.IOException
getXAttrs
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.java.io.IOException
public java.util.Map<java.lang.String,byte[]> getXAttrs(org.apache.hadoop.fs.Path path, java.util.List<java.lang.String> names) throws java.io.IOException
getXAttrs
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.names
- The names of the extended attributes (to retrieve).java.io.IOException
public java.util.List<java.lang.String> listXAttrs(org.apache.hadoop.fs.Path path) throws java.io.IOException
listXAttrs
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.java.io.IOException
public void removeXAttr(org.apache.hadoop.fs.Path path, java.lang.String name) throws java.io.IOException
removeXAttr
in class org.apache.hadoop.fs.FileSystem
path
- The path to the file or directory.name
- The name of the extended attribute (to remove). The name
must be prefixed with the namespace followed by ".". For example,
"user.attr".java.io.IOException