org.springframework.data.hadoop.fs

Class SimplerFileSystem

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.fs.FileSystem

org.springframework.data.hadoop.fs.SimplerFileSystem

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.hadoop.conf.Configurable

public class SimplerFileSystem
extends org.apache.hadoop.fs.FileSystem

FileSystem decorator that overloads methods to accept Strings instead of Paths.

Author:

Costin Leau

Nested Class Summary

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

org.apache.hadoop.fs.FileSystem.Statistics

Field Summary

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

DEFAULT_FS, FS_DEFAULT_NAME_KEY, LOG, SHUTDOWN_HOOK_PRIORITY, statistics, TRASH_PREFIX

Constructor Summary

Constructors

Constructor and Description
SimplerFileSystem(org.apache.hadoop.fs.FileSystem fs) Constructs a new SimplerFileSystem instance.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.fs.FSDataOutputStream	append(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.FSDataOutputStream	append(org.apache.hadoop.fs.Path f, int bufferSize)
org.apache.hadoop.fs.FSDataOutputStream	append(org.apache.hadoop.fs.Path f, int bufferSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	append(java.lang.String f)
org.apache.hadoop.fs.FSDataOutputStream	append(java.lang.String f, int bufferSize)
org.apache.hadoop.fs.FSDataOutputStream	append(java.lang.String f, int bufferSize, org.apache.hadoop.util.Progressable progress)
void	close()
void	completeLocalOutput(org.apache.hadoop.fs.Path fsOutputFile, org.apache.hadoop.fs.Path tmpLocalFile)
void	completeLocalOutput(java.lang.String fsOutputFile, java.lang.String tmpLocalFile)
void	copyFromLocalFile(boolean delSrc, boolean overwrite, org.apache.hadoop.fs.Path[] srcs, org.apache.hadoop.fs.Path dst)
void	copyFromLocalFile(boolean delSrc, boolean overwrite, org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	copyFromLocalFile(boolean delSrc, boolean overwrite, java.lang.String[] srcs, java.lang.String dst)
void	copyFromLocalFile(boolean delSrc, boolean overwrite, java.lang.String src, java.lang.String dst)
void	copyFromLocalFile(boolean delSrc, org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	copyFromLocalFile(boolean delSrc, java.lang.String src, java.lang.String dst)
void	copyFromLocalFile(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	copyFromLocalFile(java.lang.String src, java.lang.String dst)
void	copyToLocalFile(boolean delSrc, org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	copyToLocalFile(boolean delSrc, java.lang.String src, java.lang.String dst)
void	copyToLocalFile(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	copyToLocalFile(java.lang.String src, java.lang.String dst)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, boolean overwrite)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, boolean overwrite, int bufferSize)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, boolean overwrite, int bufferSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, boolean overwrite, int bufferSize, short replication, long blockSize)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, org.apache.hadoop.fs.permission.FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, short replication)
org.apache.hadoop.fs.FSDataOutputStream	create(org.apache.hadoop.fs.Path f, short replication, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, boolean overwrite)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, boolean overwrite, int bufferSize)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, boolean overwrite, int bufferSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, boolean overwrite, int bufferSize, short replication, long blockSize)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, org.apache.hadoop.fs.permission.FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, org.apache.hadoop.util.Progressable progress)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, short replication)
org.apache.hadoop.fs.FSDataOutputStream	create(java.lang.String f, short replication, org.apache.hadoop.util.Progressable progress)
boolean	createNewFile(org.apache.hadoop.fs.Path f)
boolean	createNewFile(java.lang.String f)
boolean	delete(org.apache.hadoop.fs.Path f)
boolean	delete(org.apache.hadoop.fs.Path f, boolean recursive)
boolean	delete(java.lang.String f)
boolean	delete(java.lang.String f, boolean recursive)
boolean	deleteOnExit(org.apache.hadoop.fs.Path f)
boolean	deleteOnExit(java.lang.String f)
boolean	equals(java.lang.Object obj)
boolean	exists(org.apache.hadoop.fs.Path f)
boolean	exists(java.lang.String f)
long	getBlockSize(org.apache.hadoop.fs.Path f)
long	getBlockSize(java.lang.String f)
java.lang.String	getCanonicalServiceName()
org.apache.hadoop.conf.Configuration	getConf()
org.apache.hadoop.fs.ContentSummary	getContentSummary(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.ContentSummary	getContentSummary(java.lang.String f)
long	getDefaultBlockSize()
short	getDefaultReplication()
org.apache.hadoop.security.token.Token<?>	getDelegationToken(java.lang.String renewer)
org.apache.hadoop.fs.BlockLocation[]	getFileBlockLocations(org.apache.hadoop.fs.FileStatus file, long start, long len)
org.apache.hadoop.fs.FileChecksum	getFileChecksum(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.FileChecksum	getFileChecksum(java.lang.String f)
org.apache.hadoop.fs.FileStatus	getFileStatus(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.FileStatus	getFileStatus(java.lang.String f)
org.apache.hadoop.fs.Path	getHomeDirectory()
long	getLength(org.apache.hadoop.fs.Path f)
long	getLength(java.lang.String f)
java.lang.String	getName()
short	getReplication(org.apache.hadoop.fs.Path src)
short	getReplication(java.lang.String src)
java.net.URI	getUri()
long	getUsed()
org.apache.hadoop.fs.Path	getWorkingDirectory()
org.apache.hadoop.fs.FileStatus[]	globStatus(org.apache.hadoop.fs.Path pathPattern)
org.apache.hadoop.fs.FileStatus[]	globStatus(org.apache.hadoop.fs.Path pathPattern, org.apache.hadoop.fs.PathFilter filter)
org.apache.hadoop.fs.FileStatus[]	globStatus(java.lang.String pathPattern)
org.apache.hadoop.fs.FileStatus[]	globStatus(java.lang.String pathPattern, org.apache.hadoop.fs.PathFilter filter)
int	hashCode()
void	initialize(java.net.URI name, org.apache.hadoop.conf.Configuration conf)
boolean	isDirectory(org.apache.hadoop.fs.Path f)
boolean	isDirectory(java.lang.String f)
boolean	isFile(org.apache.hadoop.fs.Path f)
boolean	isFile(java.lang.String f)
org.apache.hadoop.fs.FileStatus[]	listStatus(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.FileStatus[]	listStatus(org.apache.hadoop.fs.Path[] files)
org.apache.hadoop.fs.FileStatus[]	listStatus(org.apache.hadoop.fs.Path[] files, org.apache.hadoop.fs.PathFilter filter)
org.apache.hadoop.fs.FileStatus[]	listStatus(org.apache.hadoop.fs.Path f, org.apache.hadoop.fs.PathFilter filter)
org.apache.hadoop.fs.FileStatus[]	listStatus(java.lang.String f)
org.apache.hadoop.fs.FileStatus[]	listStatus(java.lang.String[] files)
org.apache.hadoop.fs.FileStatus[]	listStatus(java.lang.String[] files, org.apache.hadoop.fs.PathFilter filter)
org.apache.hadoop.fs.FileStatus[]	listStatus(java.lang.String f, org.apache.hadoop.fs.PathFilter filter)
org.apache.hadoop.fs.Path	makeQualified(org.apache.hadoop.fs.Path path)
org.apache.hadoop.fs.Path	makeQualified(java.lang.String path)
boolean	mkdirs(org.apache.hadoop.fs.Path f)
boolean	mkdirs(org.apache.hadoop.fs.Path f, org.apache.hadoop.fs.permission.FsPermission permission)
boolean	mkdirs(java.lang.String f)
boolean	mkdirs(java.lang.String f, short permission)
void	moveFromLocalFile(org.apache.hadoop.fs.Path[] srcs, org.apache.hadoop.fs.Path dst)
void	moveFromLocalFile(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	moveFromLocalFile(java.lang.String[] srcs, java.lang.String dst)
void	moveFromLocalFile(java.lang.String src, java.lang.String dst)
void	moveToLocalFile(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
void	moveToLocalFile(java.lang.String src, java.lang.String dst)
org.apache.hadoop.fs.FSDataInputStream	open(org.apache.hadoop.fs.Path f)
org.apache.hadoop.fs.FSDataInputStream	open(org.apache.hadoop.fs.Path f, int bufferSize)
org.apache.hadoop.fs.FSDataInputStream	open(java.lang.String f)
org.apache.hadoop.fs.FSDataInputStream	open(java.lang.String f, int bufferSize)
boolean	rename(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
boolean	rename(java.lang.String src, java.lang.String dst)
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	setOwner(org.apache.hadoop.fs.Path p, java.lang.String username, java.lang.String groupname)
void	setOwner(java.lang.String p, java.lang.String username, java.lang.String groupname)
void	setPermission(org.apache.hadoop.fs.Path p, org.apache.hadoop.fs.permission.FsPermission permission)
void	setPermission(java.lang.String p, short permission)
boolean	setReplication(org.apache.hadoop.fs.Path src, short replication)
boolean	setReplication(java.lang.String src, short replication)
void	setTimes(org.apache.hadoop.fs.Path p, long mtime, long atime)
void	setTimes(java.lang.String p, long mtime, long atime)
void	setVerifyChecksum(boolean verifyChecksum)
void	setWorkingDirectory(org.apache.hadoop.fs.Path new_dir)
org.apache.hadoop.fs.Path	startLocalOutput(org.apache.hadoop.fs.Path fsOutputFile, org.apache.hadoop.fs.Path tmpLocalFile)
org.apache.hadoop.fs.Path	startLocalOutput(java.lang.String fsOutputFile, java.lang.String tmpLocalFile)
java.lang.String	toString()

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

access, addDelegationTokens, areSymlinksEnabled, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, closeAll, closeAllForUGI, concat, copyToLocalFile, create, create, create, createNonRecursive, createNonRecursive, createNonRecursive, createSnapshot, createSnapshot, createSymlink, deleteSnapshot, enableSymlinks, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getCanonicalUri, getChildFileSystems, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultUri, getFileBlockLocations, getFileChecksum, getFileLinkStatus, getFileSystemClass, getFSofPath, getInitialWorkingDirectory, getLinkTarget, getLocal, getNamed, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getTracer, getTrashRoot, getTrashRoots, getXAttr, getXAttrs, getXAttrs, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatusIterator, listXAttrs, mkdirs, modifyAclEntries, newInstance, newInstance, newInstance, newInstanceLocal, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setWriteChecksum, setXAttr, setXAttr, supportsSymlinks

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SimplerFileSystem

public SimplerFileSystem(org.apache.hadoop.fs.FileSystem fs)

Constructs a new SimplerFileSystem instance.

Parameters:

fs - Hadoop file system to use.

Method Detail

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

getConf

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

Specified by:

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

Overrides:

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

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

initialize

public void initialize(java.net.URI name,
              org.apache.hadoop.conf.Configuration conf)
                throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getUri

public java.net.URI getUri()

Specified by:

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

getCanonicalServiceName

public java.lang.String getCanonicalServiceName()

Overrides:

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

getName

public java.lang.String getName()

Overrides:

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

makeQualified

public org.apache.hadoop.fs.Path makeQualified(java.lang.String path)

makeQualified

public org.apache.hadoop.fs.Path makeQualified(org.apache.hadoop.fs.Path path)

Overrides:

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

getFileBlockLocations

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

Overrides:

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

Throws:

java.io.IOException

open

public org.apache.hadoop.fs.FSDataInputStream open(java.lang.String f,
                                          int bufferSize)
                                            throws java.io.IOException

Throws:

java.io.IOException

open

public org.apache.hadoop.fs.FSDataInputStream open(org.apache.hadoop.fs.Path f,
                                          int bufferSize)
                                            throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

open

public org.apache.hadoop.fs.FSDataInputStream open(java.lang.String f)
                                            throws java.io.IOException

Throws:

java.io.IOException

open

public org.apache.hadoop.fs.FSDataInputStream open(org.apache.hadoop.fs.Path f)
                                            throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             boolean overwrite)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             boolean overwrite)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             short replication)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             short replication)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             short replication,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             short replication,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             boolean overwrite,
                                             int bufferSize)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             boolean overwrite,
                                             int bufferSize)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             boolean overwrite,
                                             int bufferSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             boolean overwrite,
                                             int bufferSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             boolean overwrite,
                                             int bufferSize,
                                             short replication,
                                             long blockSize)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             boolean overwrite,
                                             int bufferSize,
                                             short replication,
                                             long blockSize)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             boolean overwrite,
                                             int bufferSize,
                                             short replication,
                                             long blockSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             boolean overwrite,
                                             int bufferSize,
                                             short replication,
                                             long blockSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path f,
                                             org.apache.hadoop.fs.permission.FsPermission permission,
                                             boolean overwrite,
                                             int bufferSize,
                                             short replication,
                                             long blockSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

create

public org.apache.hadoop.fs.FSDataOutputStream create(java.lang.String f,
                                             org.apache.hadoop.fs.permission.FsPermission permission,
                                             boolean overwrite,
                                             int bufferSize,
                                             short replication,
                                             long blockSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Throws:

java.io.IOException

createNewFile

public boolean createNewFile(java.lang.String f)
                      throws java.io.IOException

Throws:

java.io.IOException

createNewFile

public boolean createNewFile(org.apache.hadoop.fs.Path f)
                      throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

append

public org.apache.hadoop.fs.FSDataOutputStream append(java.lang.String f)
                                               throws java.io.IOException

Throws:

java.io.IOException

append

public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path f)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

append

public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path f,
                                             int bufferSize)
                                               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

append

public org.apache.hadoop.fs.FSDataOutputStream append(java.lang.String f,
                                             int bufferSize)
                                               throws java.io.IOException

Throws:

java.io.IOException

append

public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path f,
                                             int bufferSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

append

public org.apache.hadoop.fs.FSDataOutputStream append(java.lang.String f,
                                             int bufferSize,
                                             org.apache.hadoop.util.Progressable progress)
                                               throws java.io.IOException

Throws:

java.io.IOException

getReplication

public short getReplication(org.apache.hadoop.fs.Path src)
                     throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getReplication

public short getReplication(java.lang.String src)
                     throws java.io.IOException

Throws:

java.io.IOException

setReplication

public boolean setReplication(org.apache.hadoop.fs.Path src,
                     short replication)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

setReplication

public boolean setReplication(java.lang.String src,
                     short replication)
                       throws java.io.IOException

Throws:

java.io.IOException

rename

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

Specified by:

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

Throws:

java.io.IOException

rename

public boolean rename(java.lang.String src,
             java.lang.String dst)
               throws java.io.IOException

Throws:

java.io.IOException

delete

public boolean delete(org.apache.hadoop.fs.Path f)
               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

delete

public boolean delete(java.lang.String f)
               throws java.io.IOException

Throws:

java.io.IOException

delete

public boolean delete(org.apache.hadoop.fs.Path f,
             boolean recursive)
               throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

delete

public boolean delete(java.lang.String f,
             boolean recursive)
               throws java.io.IOException

Throws:

java.io.IOException

deleteOnExit

public boolean deleteOnExit(org.apache.hadoop.fs.Path f)
                     throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

deleteOnExit

public boolean deleteOnExit(java.lang.String f)
                     throws java.io.IOException

Throws:

java.io.IOException

exists

public boolean exists(org.apache.hadoop.fs.Path f)
               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

exists

public boolean exists(java.lang.String f)
               throws java.io.IOException

Throws:

java.io.IOException

isDirectory

public boolean isDirectory(org.apache.hadoop.fs.Path f)
                    throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

isDirectory

public boolean isDirectory(java.lang.String f)
                    throws java.io.IOException

Throws:

java.io.IOException

isFile

public boolean isFile(org.apache.hadoop.fs.Path f)
               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

isFile

public boolean isFile(java.lang.String f)
               throws java.io.IOException

Throws:

java.io.IOException

getLength

public long getLength(org.apache.hadoop.fs.Path f)
               throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getLength

public long getLength(java.lang.String f)
               throws java.io.IOException

Throws:

java.io.IOException

getContentSummary

public org.apache.hadoop.fs.ContentSummary getContentSummary(org.apache.hadoop.fs.Path f)
                                                      throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getContentSummary

public org.apache.hadoop.fs.ContentSummary getContentSummary(java.lang.String f)
                                                      throws java.io.IOException

Throws:

java.io.IOException

listStatus

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

Specified by:

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

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(java.lang.String f)
                                             throws java.io.IOException

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path f,
                                           org.apache.hadoop.fs.PathFilter filter)
                                             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(java.lang.String f,
                                           org.apache.hadoop.fs.PathFilter filter)
                                             throws java.io.IOException

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path[] files)
                                             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(java.lang.String[] files)
                                             throws java.io.IOException

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path[] files,
                                           org.apache.hadoop.fs.PathFilter filter)
                                             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

listStatus

public org.apache.hadoop.fs.FileStatus[] listStatus(java.lang.String[] files,
                                           org.apache.hadoop.fs.PathFilter filter)
                                             throws java.io.IOException

Throws:

java.io.IOException

globStatus

public org.apache.hadoop.fs.FileStatus[] globStatus(org.apache.hadoop.fs.Path pathPattern)
                                             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

globStatus

public org.apache.hadoop.fs.FileStatus[] globStatus(java.lang.String pathPattern)
                                             throws java.io.IOException

Throws:

java.io.IOException

globStatus

public org.apache.hadoop.fs.FileStatus[] globStatus(org.apache.hadoop.fs.Path pathPattern,
                                           org.apache.hadoop.fs.PathFilter filter)
                                             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

globStatus

public org.apache.hadoop.fs.FileStatus[] globStatus(java.lang.String pathPattern,
                                           org.apache.hadoop.fs.PathFilter filter)
                                             throws java.io.IOException

Throws:

java.io.IOException

getHomeDirectory

public org.apache.hadoop.fs.Path getHomeDirectory()

Overrides:

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

getDelegationToken

public org.apache.hadoop.security.token.Token<?> getDelegationToken(java.lang.String renewer)
                                                             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

setWorkingDirectory

public void setWorkingDirectory(org.apache.hadoop.fs.Path new_dir)

Specified by:

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

getWorkingDirectory

public org.apache.hadoop.fs.Path getWorkingDirectory()

Specified by:

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

mkdirs

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

Overrides:

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

Throws:

java.io.IOException

mkdirs

public boolean mkdirs(java.lang.String f)
               throws java.io.IOException

Throws:

java.io.IOException

mkdirs

public boolean mkdirs(org.apache.hadoop.fs.Path f,
             org.apache.hadoop.fs.permission.FsPermission permission)
               throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException

mkdirs

public boolean mkdirs(java.lang.String f,
             short permission)
               throws java.io.IOException

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(org.apache.hadoop.fs.Path src,
                     org.apache.hadoop.fs.Path dst)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(java.lang.String src,
                     java.lang.String dst)
                       throws java.io.IOException

Throws:

java.io.IOException

moveFromLocalFile

public void moveFromLocalFile(org.apache.hadoop.fs.Path[] srcs,
                     org.apache.hadoop.fs.Path dst)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

moveFromLocalFile

public void moveFromLocalFile(java.lang.String[] srcs,
                     java.lang.String dst)
                       throws java.io.IOException

Throws:

java.io.IOException

moveFromLocalFile

public void moveFromLocalFile(org.apache.hadoop.fs.Path src,
                     org.apache.hadoop.fs.Path dst)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

moveFromLocalFile

public void moveFromLocalFile(java.lang.String src,
                     java.lang.String dst)
                       throws java.io.IOException

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     org.apache.hadoop.fs.Path src,
                     org.apache.hadoop.fs.Path dst)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     java.lang.String src,
                     java.lang.String dst)
                       throws java.io.IOException

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     boolean overwrite,
                     org.apache.hadoop.fs.Path[] srcs,
                     org.apache.hadoop.fs.Path dst)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     boolean overwrite,
                     java.lang.String[] srcs,
                     java.lang.String dst)
                       throws java.io.IOException

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     boolean overwrite,
                     org.apache.hadoop.fs.Path src,
                     org.apache.hadoop.fs.Path dst)
                       throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

copyFromLocalFile

public void copyFromLocalFile(boolean delSrc,
                     boolean overwrite,
                     java.lang.String src,
                     java.lang.String dst)
                       throws java.io.IOException

Throws:

java.io.IOException

copyToLocalFile

public void copyToLocalFile(org.apache.hadoop.fs.Path src,
                   org.apache.hadoop.fs.Path dst)
                     throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

copyToLocalFile

public void copyToLocalFile(java.lang.String src,
                   java.lang.String dst)
                     throws java.io.IOException

Throws:

java.io.IOException

moveToLocalFile

public void moveToLocalFile(org.apache.hadoop.fs.Path src,
                   org.apache.hadoop.fs.Path dst)
                     throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

moveToLocalFile

public void moveToLocalFile(java.lang.String src,
                   java.lang.String dst)
                     throws java.io.IOException

Throws:

java.io.IOException

copyToLocalFile

public void copyToLocalFile(boolean delSrc,
                   org.apache.hadoop.fs.Path src,
                   org.apache.hadoop.fs.Path dst)
                     throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

copyToLocalFile

public void copyToLocalFile(boolean delSrc,
                   java.lang.String src,
                   java.lang.String dst)
                     throws java.io.IOException

Throws:

java.io.IOException

startLocalOutput

public org.apache.hadoop.fs.Path startLocalOutput(org.apache.hadoop.fs.Path fsOutputFile,
                                         org.apache.hadoop.fs.Path tmpLocalFile)
                                           throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

startLocalOutput

public org.apache.hadoop.fs.Path startLocalOutput(java.lang.String fsOutputFile,
                                         java.lang.String tmpLocalFile)
                                           throws java.io.IOException

Throws:

java.io.IOException

completeLocalOutput

public void completeLocalOutput(org.apache.hadoop.fs.Path fsOutputFile,
                       org.apache.hadoop.fs.Path tmpLocalFile)
                         throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

completeLocalOutput

public void completeLocalOutput(java.lang.String fsOutputFile,
                       java.lang.String tmpLocalFile)
                         throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

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

Throws:

java.io.IOException

getUsed

public long getUsed()
             throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getBlockSize

public long getBlockSize(org.apache.hadoop.fs.Path f)
                  throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getBlockSize

public long getBlockSize(java.lang.String f)
                  throws java.io.IOException

Throws:

java.io.IOException

getDefaultBlockSize

public long getDefaultBlockSize()

Overrides:

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

getDefaultReplication

public short getDefaultReplication()

Overrides:

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

getFileStatus

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

Specified by:

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

Throws:

java.io.IOException

getFileStatus

public org.apache.hadoop.fs.FileStatus getFileStatus(java.lang.String f)
                                              throws java.io.IOException

Throws:

java.io.IOException

getFileChecksum

public org.apache.hadoop.fs.FileChecksum getFileChecksum(org.apache.hadoop.fs.Path f)
                                                  throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

getFileChecksum

public org.apache.hadoop.fs.FileChecksum getFileChecksum(java.lang.String f)
                                                  throws java.io.IOException

Throws:

java.io.IOException

setVerifyChecksum

public void setVerifyChecksum(boolean verifyChecksum)

Overrides:

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

setPermission

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

Overrides:

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

Throws:

java.io.IOException

setPermission

public void setPermission(java.lang.String p,
                 short permission)
                   throws java.io.IOException

Throws:

java.io.IOException

setOwner

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

Overrides:

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

Throws:

java.io.IOException

setOwner

public void setOwner(java.lang.String p,
            java.lang.String username,
            java.lang.String groupname)
              throws java.io.IOException

Throws:

java.io.IOException

setTimes

public void setTimes(org.apache.hadoop.fs.Path p,
            long mtime,
            long atime)
              throws java.io.IOException

Overrides:

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

Throws:

java.io.IOException

setTimes

public void setTimes(java.lang.String p,
            long mtime,
            long atime)
              throws java.io.IOException

Throws:

java.io.IOException