Overview  Package   Class  Tree  Deprecated  Index  Help 
Spring for Apache Hadoop
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.springframework.data.hadoop.fs
Class SimplerFileSystem

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.hadoop.fs.FileSystem
          extended by org.springframework.data.hadoop.fs.SimplerFileSystem
All Implemented Interfaces:
java.io.Closeable, 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
 
Constructor Summary
SimplerFileSystem(org.apache.hadoop.fs.FileSystem fs)
          Constructs a new SimplerFileSystem instance.
 
Method Summary
 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
addDelegationTokens, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, closeAll, closeAllForUGI, concat, copyToLocalFile, create, create, create, createNonRecursive, createNonRecursive, createNonRecursive, createSnapshot, createSnapshot, createSymlink, deleteSnapshot, enableSymlinks, fixRelativePart, get, get, get, getAllStatistics, getCanonicalUri, getChildFileSystems, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultUri, getFileBlockLocations, getFileLinkStatus, getFileSystemClass, getFSofPath, getInitialWorkingDirectory, getLinkTarget, getLocal, getNamed, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, isSymlinksEnabled, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, mkdirs, newInstance, newInstance, newInstance, newInstanceLocal, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, rename, renameSnapshot, resolveLink, resolvePath, setDefaultUri, setDefaultUri, setWriteChecksum, 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
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
Overview  Package   Class  Tree  Deprecated  Index  Help 
Spring for Apache Hadoop
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD