org.apache.hadoop.fs.glusterfs

Class GlusterVolume

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.fs.FileSystem

org.apache.hadoop.fs.RawLocalFileSystem

org.apache.hadoop.fs.glusterfs.GlusterVolume

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.conf.Configurable

public class GlusterVolume
extends org.apache.hadoop.fs.RawLocalFileSystem

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.fs.FileSystem

org.apache.hadoop.fs.FileSystem.Statistics

Field Summary

Fields

Modifier and Type	Field and Description
protected static GlusterFSXattr	attr
static int	DEFAULT_BLOCK_SIZE
protected String	default_volume
protected URI	NAME
static int	OPTIMAL_WRITE_BUFFER_SIZE
static int	OVERRIDE_WRITE_BUFFER_SIZE General reason for these constants is to help us decide when to override the specified buffer size.
protected Hashtable<String,String>	volumes

Fields inherited from class org.apache.hadoop.fs.FileSystem

DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics

Constructor Summary

Constructors

Constructor and Description
GlusterVolume()
GlusterVolume(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected URI	canonicalizeUri(URI uri)
boolean	delete(org.apache.hadoop.fs.Path p, boolean recursive) Delete the given path to a file or directory.
org.apache.hadoop.fs.Path	fileToPath(File path)
long	getBlockSize(org.apache.hadoop.fs.Path path)
org.apache.hadoop.fs.BlockLocation[]	getFileBlockLocations(org.apache.hadoop.fs.FileStatus file, long start, long len)
org.apache.hadoop.fs.FileStatus	getFileStatus(org.apache.hadoop.fs.Path f)
protected org.apache.hadoop.fs.Path	getInitialWorkingDirectory()
URI	getUri()
void	initialize(URI uri, org.apache.hadoop.conf.Configuration conf)
org.apache.hadoop.fs.FileStatus[]	listStatus(org.apache.hadoop.fs.Path f)
boolean	mkdirs(org.apache.hadoop.fs.Path f)
File	pathToFile(org.apache.hadoop.fs.Path path)
boolean	rename(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
boolean	sameVolume(org.apache.hadoop.fs.Path p)
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	setOwner(org.apache.hadoop.fs.Path p, String username, String groupname)
void	setPermission(org.apache.hadoop.fs.Path p, org.apache.hadoop.fs.permission.FsPermission permission)
String	toString()

Methods inherited from class org.apache.hadoop.fs.RawLocalFileSystem

append, close, completeLocalOutput, create, create, createNonRecursive, createNonRecursive, createSymlink, getFileLinkStatus, getHomeDirectory, getLinkTarget, getStatus, getWorkingDirectory, mkdirs, moveFromLocalFile, open, primitiveMkdir, setTimes, setWorkingDirectory, startLocalOutput, supportsSymlinks, useStatIfAvailable

Methods inherited from class org.apache.hadoop.fs.FileSystem

addDelegationTokens, append, append, areSymlinksEnabled, cancelDeleteOnExit, checkPath, clearStatistics, closeAll, closeAllForUGI, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, createNewFile, createNonRecursive, createSnapshot, createSnapshot, delete, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getCanonicalServiceName, getCanonicalUri, getChildFileSystems, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileChecksum, getFileSystemClass, getFSofPath, getLength, getLocal, getName, getNamed, getReplication, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getUsed, globStatus, globStatus, isDirectory, isFile, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, makeQualified, mkdirs, modifyAclEntries, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, primitiveCreate, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setReplication, setVerifyChecksum, setWriteChecksum

Methods inherited from class org.apache.hadoop.conf.Configured

getConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

OVERRIDE_WRITE_BUFFER_SIZE

public static final int OVERRIDE_WRITE_BUFFER_SIZE

General reason for these constants is to help us decide when to override the specified buffer size. See implementation of logic below, which might change overtime.

See Also:

Constant Field Values

OPTIMAL_WRITE_BUFFER_SIZE

public static final int OPTIMAL_WRITE_BUFFER_SIZE

See Also:

Constant Field Values

DEFAULT_BLOCK_SIZE

public static final int DEFAULT_BLOCK_SIZE

See Also:

Constant Field Values

NAME

protected URI NAME

volumes

protected Hashtable<String,String> volumes

default_volume

protected String default_volume

attr

protected static GlusterFSXattr attr

Constructor Detail

GlusterVolume

public GlusterVolume()

GlusterVolume

public GlusterVolume(org.apache.hadoop.conf.Configuration conf)

Method Detail

getUri

public URI getUri()

Overrides:

getUri in class org.apache.hadoop.fs.RawLocalFileSystem

initialize

public void initialize(URI uri,
                       org.apache.hadoop.conf.Configuration conf)
                throws IOException

Overrides:

initialize in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

canonicalizeUri

protected URI canonicalizeUri(URI uri)

Overrides:

canonicalizeUri in class org.apache.hadoop.fs.FileSystem

sameVolume

public boolean sameVolume(org.apache.hadoop.fs.Path p)

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

Overrides:

setConf in class org.apache.hadoop.conf.Configured

pathToFile

public File pathToFile(org.apache.hadoop.fs.Path path)

Overrides:

pathToFile in class org.apache.hadoop.fs.RawLocalFileSystem

getInitialWorkingDirectory

protected org.apache.hadoop.fs.Path getInitialWorkingDirectory()

Overrides:

getInitialWorkingDirectory in class org.apache.hadoop.fs.RawLocalFileSystem

fileToPath

public org.apache.hadoop.fs.Path fileToPath(File path)

rename

public boolean rename(org.apache.hadoop.fs.Path src,
                      org.apache.hadoop.fs.Path dst)
               throws IOException

Overrides:

rename in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

delete

public boolean delete(org.apache.hadoop.fs.Path p,
                      boolean recursive)
               throws IOException

Delete the given path to a file or directory.

Overrides:

delete in class org.apache.hadoop.fs.RawLocalFileSystem

Parameters:

p - the path to delete

recursive - to delete sub-directories

Returns:

true if the file or directory and all its contents were deleted

Throws:

IOException - if p is non-empty and recursive is false

mkdirs

public boolean mkdirs(org.apache.hadoop.fs.Path f)
               throws IOException

Overrides:

mkdirs in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path f)
                                             throws IOException

Overrides:

listStatus in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

getFileStatus

public org.apache.hadoop.fs.FileStatus getFileStatus(org.apache.hadoop.fs.Path f)
                                              throws IOException

Overrides:

getFileStatus in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

getBlockSize

public long getBlockSize(org.apache.hadoop.fs.Path path)
                  throws IOException

Overrides:

getBlockSize in class org.apache.hadoop.fs.FileSystem

Throws:

IOException

setOwner

public void setOwner(org.apache.hadoop.fs.Path p,
                     String username,
                     String groupname)
              throws IOException

Overrides:

setOwner in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

setPermission

public void setPermission(org.apache.hadoop.fs.Path p,
                          org.apache.hadoop.fs.permission.FsPermission permission)
                   throws IOException

Overrides:

setPermission in class org.apache.hadoop.fs.RawLocalFileSystem

Throws:

IOException

getFileBlockLocations

public org.apache.hadoop.fs.BlockLocation[] getFileBlockLocations(org.apache.hadoop.fs.FileStatus file,
                                                                  long start,
                                                                  long len)
                                                           throws IOException

Overrides:

getFileBlockLocations in class org.apache.hadoop.fs.FileSystem

Throws:

IOException

toString

public String toString()

Overrides:

toString in class org.apache.hadoop.fs.RawLocalFileSystem