Uses of Class
org.apache.hadoop.fs.Path

Packages that use Path
org.apache.hadoop.conf Configuration of system parameters. 
org.apache.hadoop.contrib.index.lucene   
org.apache.hadoop.contrib.index.mapred   
org.apache.hadoop.examples.terasort This package consists of 3 map/reduce applications for Hadoop to compete in the annual terabyte sort competition. 
org.apache.hadoop.filecache   
org.apache.hadoop.fs An abstract file system API. 
org.apache.hadoop.fs.ftp   
org.apache.hadoop.fs.kfs A client for the Kosmos filesystem (KFS) 
org.apache.hadoop.fs.s3 A distributed, block-based implementation of FileSystem that uses Amazon S3 as a backing store. 
org.apache.hadoop.fs.s3native A distributed implementation of FileSystem for reading and writing files on Amazon S3
org.apache.hadoop.fs.shell   
org.apache.hadoop.io Generic i/o code for use when reading and writing data to the network, to databases, and to files. 
org.apache.hadoop.io.compress   
org.apache.hadoop.mapred A software framework for easily writing applications which process vast amounts of data (multi-terabyte data-sets) parallelly on large clusters (thousands of nodes) built of commodity hardware in a reliable, fault-tolerant manner. 
org.apache.hadoop.mapred.join Given a set of sorted datasets keyed with the same class and yielding equal partitions, it is possible to effect a join of those datasets prior to the map. 
org.apache.hadoop.mapred.lib Library of generally useful mappers, reducers, and partitioners. 
org.apache.hadoop.mapreduce   
org.apache.hadoop.mapreduce.lib.input   
org.apache.hadoop.mapreduce.lib.output   
org.apache.hadoop.mapreduce.lib.partition   
org.apache.hadoop.mapreduce.security   
org.apache.hadoop.mapreduce.split   
org.apache.hadoop.security   
org.apache.hadoop.util Common utilities. 
 

Uses of Path in org.apache.hadoop.conf
 

Methods in org.apache.hadoop.conf that return Path
 Path Configuration.getLocalPath(String dirsProp, String path)
          Get a local file under a directory named by dirsProp with the given path.
 

Methods in org.apache.hadoop.conf with parameters of type Path
 void Configuration.addResource(Path file)
          Add a configuration resource.
 

Uses of Path in org.apache.hadoop.contrib.index.lucene
 

Constructors in org.apache.hadoop.contrib.index.lucene with parameters of type Path
FileSystemDirectory(FileSystem fs, Path directory, boolean create, Configuration conf)
          Constructor
 

Uses of Path in org.apache.hadoop.contrib.index.mapred
 

Methods in org.apache.hadoop.contrib.index.mapred with parameters of type Path
 void IndexUpdater.run(Configuration conf, Path[] inputPaths, Path outputPath, int numMapTasks, Shard[] shards)
           
 void IndexUpdater.run(Configuration conf, Path[] inputPaths, Path outputPath, int numMapTasks, Shard[] shards)
           
 void IIndexUpdater.run(Configuration conf, Path[] inputPaths, Path outputPath, int numMapTasks, Shard[] shards)
          Create a Map/Reduce job configuration and run the Map/Reduce job to analyze documents and update Lucene instances in parallel.
 void IIndexUpdater.run(Configuration conf, Path[] inputPaths, Path outputPath, int numMapTasks, Shard[] shards)
          Create a Map/Reduce job configuration and run the Map/Reduce job to analyze documents and update Lucene instances in parallel.
 

Uses of Path in org.apache.hadoop.examples.terasort
 

Methods in org.apache.hadoop.examples.terasort with parameters of type Path
static void TeraInputFormat.writePartitionFile(JobConf conf, Path partFile)
          Use the input splits to take samples of the input and generate sample keys.
 

Uses of Path in org.apache.hadoop.filecache
 

Methods in org.apache.hadoop.filecache that return Path
static Path[] DistributedCache.getArchiveClassPaths(Configuration conf)
          Get the archive entries in classpath as an array of Path.
static Path[] DistributedCache.getFileClassPaths(Configuration conf)
          Get the file entries in classpath as an array of Path.
static Path[] DistributedCache.getLocalCacheArchives(Configuration conf)
          Return the path array of the localized caches.
static Path[] DistributedCache.getLocalCacheFiles(Configuration conf)
          Return the path array of the localized files.
 

Methods in org.apache.hadoop.filecache with parameters of type Path
static void DistributedCache.addArchiveToClassPath(Path archive, Configuration conf)
          Deprecated. Please use DistributedCache.addArchiveToClassPath(Path, Configuration, FileSystem) instead. The FileSystem should be obtained within an appropriate doAs.
static void DistributedCache.addArchiveToClassPath(Path archive, Configuration conf, FileSystem fs)
          Add an archive path to the current set of classpath entries.
static void DistributedCache.addFileToClassPath(Path file, Configuration conf)
          Deprecated. Please use DistributedCache.addFileToClassPath(Path, Configuration, FileSystem) instead. The FileSystem should be obtained within an appropriate doAs.
static void DistributedCache.addFileToClassPath(Path file, Configuration conf, FileSystem fs)
          Add a file path to the current set of classpath entries.
static long TrackerDistributedCacheManager.downloadCacheObject(Configuration conf, URI source, Path destination, long desiredTimestamp, boolean isArchive, FsPermission permission)
          Download a given path to the local file system.
 

Uses of Path in org.apache.hadoop.fs
 

Fields in org.apache.hadoop.fs declared as Path
protected  Path FSInputChecker.file
          The file name from which data is read from
 

Methods in org.apache.hadoop.fs that return Path
 Path ChecksumFileSystem.getChecksumFile(Path file)
          Return the name of the checksum file associated with a file.
 Path FsShell.getCurrentTrashDir()
          Returns the Trash object associated with this shell.
 Path[] InMemoryFileSystem.getFiles(PathFilter filter)
          Deprecated.  
 Path FilterFileSystem.getHomeDirectory()
           
 Path HarFileSystem.getHomeDirectory()
          return the top level archive path.
 Path RawLocalFileSystem.getHomeDirectory()
           
 Path FileSystem.getHomeDirectory()
          Return the current user's home directory in this filesystem.
 Path LocalDirAllocator.getLocalPathForWrite(String pathStr, Configuration conf)
          Get a path from the local FS.
 Path LocalDirAllocator.getLocalPathForWrite(String pathStr, long size, Configuration conf)
          Get a path from the local FS.
 Path LocalDirAllocator.getLocalPathForWrite(String pathStr, long size, Configuration conf, boolean checkWrite)
          Get a path from the local FS.
 Path LocalDirAllocator.getLocalPathToRead(String pathStr, Configuration conf)
          Get a path from the local FS for reading.
 Path Path.getParent()
          Returns the parent of a path or null if at root.
 Path FileStatus.getPath()
           
 Path FilterFileSystem.getWorkingDirectory()
          Get the current working directory for the given file system
 Path HarFileSystem.getWorkingDirectory()
          return the top level archive.
 Path RawLocalFileSystem.getWorkingDirectory()
           
abstract  Path FileSystem.getWorkingDirectory()
          Get the current working directory for the given file system
 Path Path.makeQualified(FileSystem fs)
          Returns a qualified path object.
 Path FilterFileSystem.makeQualified(Path path)
          Make sure that a path specifies a FileSystem.
 Path HarFileSystem.makeQualified(Path path)
           
 Path FileSystem.makeQualified(Path path)
          Make sure that a path specifies a FileSystem.
 Path Path.makeQualified(URI defaultUri, Path workingDir)
          Returns a qualified path object.
 Path FilterFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          Returns a local File that the user can write output to.
 Path ChecksumFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 Path HarFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          not implemented.
 Path RawLocalFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 Path FileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          Returns a local File that the user can write output to.
static Path[] FileUtil.stat2Paths(FileStatus[] stats)
          convert an array of FileStatus to an array of Path
static Path[] FileUtil.stat2Paths(FileStatus[] stats, Path path)
          convert an array of FileStatus to an array of Path.
 Path Path.suffix(String suffix)
          Adds a suffix to the final name in the path.
 

Methods in org.apache.hadoop.fs that return types with arguments of type Path
 Iterable<Path> LocalDirAllocator.getAllLocalPathsToRead(String pathStr, Configuration conf)
          Get all of the paths that currently exist in the working directories.
 

Methods in org.apache.hadoop.fs with parameters of type Path
 boolean PathFilter.accept(Path path)
          Tests whether or not the specified abstract pathname should be included in a pathname list.
 FSDataOutputStream FileSystem.append(Path f)
          Append to an existing file (optional operation).
 FSDataOutputStream FileSystem.append(Path f, int bufferSize)
          Append to an existing file (optional operation).
 FSDataOutputStream FilterFileSystem.append(Path f, int bufferSize, Progressable progress)
          Append to an existing file (optional operation).
 FSDataOutputStream ChecksumFileSystem.append(Path f, int bufferSize, Progressable progress)
          Append to an existing file (optional operation).
 FSDataOutputStream RawLocalFileSystem.append(Path f, int bufferSize, Progressable progress)
          Append to an existing file (optional operation).
abstract  FSDataOutputStream FileSystem.append(Path f, int bufferSize, Progressable progress)
          Append to an existing file (optional operation).
protected  void FilterFileSystem.checkPath(Path path)
          Check that a Path belongs to this FileSystem.
protected  void FileSystem.checkPath(Path path)
          Check that a Path belongs to this FileSystem.
 void FilterFileSystem.completeLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          Called when we're all done writing to the target.
 void ChecksumFileSystem.completeLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 void HarFileSystem.completeLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          not implemented.
 void RawLocalFileSystem.completeLocalOutput(Path fsWorkingFile, Path tmpLocalFile)
           
 void FileSystem.completeLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          Called when we're all done writing to the target.
 void FilterFileSystem.concat(Path f, Path[] psrcs)
           
 void FilterFileSystem.concat(Path f, Path[] psrcs)
           
 void FileSystem.concat(Path trg, Path[] srcs)
          Concat existing files together.
 void FileSystem.concat(Path trg, Path[] srcs)
          Concat existing files together.
static boolean FileUtil.copy(File src, FileSystem dstFS, Path dst, boolean deleteSource, Configuration conf)
          Copy local files to a FileSystem.
static boolean FileUtil.copy(FileSystem srcFS, Path[] srcs, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf)
           
static boolean FileUtil.copy(FileSystem srcFS, Path[] srcs, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf)
           
static boolean FileUtil.copy(FileSystem srcFS, Path src, File dst, boolean deleteSource, Configuration conf)
          Copy FileSystem files to local files.
static boolean FileUtil.copy(FileSystem srcFS, Path src, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf)
          Copy files between FileSystems.
static boolean FileUtil.copy(FileSystem srcFS, Path src, FileSystem dstFS, Path dst, boolean deleteSource, Configuration conf)
          Copy files between FileSystems.
 void FileSystem.copyFromLocalFile(boolean delSrc, boolean overwrite, Path[] srcs, Path dst)
          The src files are on the local disk.
 void FileSystem.copyFromLocalFile(boolean delSrc, boolean overwrite, Path[] srcs, Path dst)
          The src files are on the local disk.
 void FileSystem.copyFromLocalFile(boolean delSrc, boolean overwrite, Path src, Path dst)
          The src file is on the local disk.
 void FilterFileSystem.copyFromLocalFile(boolean delSrc, Path src, Path dst)
          The src file is on the local disk.
 void ChecksumFileSystem.copyFromLocalFile(boolean delSrc, Path src, Path dst)
           
 void HarFileSystem.copyFromLocalFile(boolean delSrc, Path src, Path dst)
          not implemented.
 void LocalFileSystem.copyFromLocalFile(boolean delSrc, Path src, Path dst)
           
 void FileSystem.copyFromLocalFile(boolean delSrc, Path src, Path dst)
          The src file is on the local disk.
 void FileSystem.copyFromLocalFile(Path src, Path dst)
          The src file is on the local disk.
static boolean FileUtil.copyMerge(FileSystem srcFS, Path srcDir, FileSystem dstFS, Path dstFile, boolean deleteSource, Configuration conf, String addString)
          Copy all files in a directory to one output file (merge).
 void FilterFileSystem.copyToLocalFile(boolean delSrc, Path src, Path dst)
          The src file is under FS, and the dst is on the local disk.
 void ChecksumFileSystem.copyToLocalFile(boolean delSrc, Path src, Path dst)
          The src file is under FS, and the dst is on the local disk.
 void HarFileSystem.copyToLocalFile(boolean delSrc, Path src, Path dst)
          copies the file in the har filesystem to a local file.
 void LocalFileSystem.copyToLocalFile(boolean delSrc, Path src, Path dst)
           
 void FileSystem.copyToLocalFile(boolean delSrc, Path src, Path dst)
          The src file is under FS, and the dst is on the local disk.
 void FileSystem.copyToLocalFile(Path src, Path dst)
          The src file is under FS, and the dst is on the local disk.
 void ChecksumFileSystem.copyToLocalFile(Path src, Path dst, boolean copyCrc)
          The src file is under FS, and the dst is on the local disk.
static FSDataOutputStream FileSystem.create(FileSystem fs, Path file, FsPermission permission)
          create a file with the provided permission The permission of the file is set to be the provided permission as in setPermission, not permission&~umask It is implemented using two RPCs.
 FSDataOutputStream FileSystem.create(Path f)
          Opens an FSDataOutputStream at the indicated Path.
 FSDataOutputStream FileSystem.create(Path f, boolean overwrite)
          Opens an FSDataOutputStream at the indicated Path.
 FSDataOutputStream FileSystem.create(Path f, boolean overwrite, int bufferSize)
          Opens an FSDataOutputStream at the indicated Path.
 FSDataOutputStream FileSystem.create(Path f, boolean overwrite, int bufferSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream FileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)
          Opens an FSDataOutputStream at the indicated Path.
 FSDataOutputStream RawLocalFileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream FileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream FilterFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
           
 FSDataOutputStream ChecksumFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream HarFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
           
 FSDataOutputStream RawLocalFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
abstract  FSDataOutputStream FileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream HarFileSystem.create(Path f, int bufferSize)
           
 FSDataOutputStream FileSystem.create(Path f, Progressable progress)
          Create an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream FileSystem.create(Path f, short replication)
          Opens an FSDataOutputStream at the indicated Path.
 FSDataOutputStream FileSystem.create(Path f, short replication, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 boolean FileSystem.createNewFile(Path f)
          Creates the given Path as a brand-new zero-length file.
 FSDataOutputStream FileSystem.createNonRecursive(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Deprecated. API only for 0.20-append
 FSDataOutputStream ChecksumFileSystem.createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream RawLocalFileSystem.createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
 FSDataOutputStream FileSystem.createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          Deprecated. API only for 0.20-append
 boolean FilterFileSystem.delete(Path f)
          Deprecated. 
 boolean RawLocalFileSystem.delete(Path p)
          Deprecated. 
abstract  boolean FileSystem.delete(Path f)
          Deprecated. Use delete(Path, boolean) instead
 boolean FilterFileSystem.delete(Path f, boolean recursive)
          Delete a file
 boolean ChecksumFileSystem.delete(Path f, boolean recursive)
          Implement the delete(Path, boolean) in checksum file system.
 boolean HarFileSystem.delete(Path f, boolean recursive)
          Not implemented.
 boolean RawLocalFileSystem.delete(Path p, boolean recursive)
           
abstract  boolean FileSystem.delete(Path f, boolean recursive)
          Delete a file.
 boolean FileSystem.deleteOnExit(Path f)
          Mark a path to be deleted when FileSystem is closed.
 boolean LocalFileSystem.exists(Path f)
          Get file status.
 boolean FileSystem.exists(Path f)
          Check if exists.
static void FileUtil.fullyDelete(FileSystem fs, Path dir)
          Deprecated. Use FileSystem.delete(Path, boolean)
 long FileSystem.getBlockSize(Path f)
          Deprecated. Use getFileStatus() instead
 Path ChecksumFileSystem.getChecksumFile(Path file)
          Return the name of the checksum file associated with a file.
 long ChecksumFileSystem.getChecksumFileLength(Path file, long fileSize)
          Return the length of the checksum file given the size of the actual file.
 ContentSummary FileSystem.getContentSummary(Path f)
          Return the ContentSummary of a given Path.
 long FileSystem.getDefaultBlockSize(Path f)
          Return the number of bytes that large input files should be optimally be split into to minimize i/o time.
 short FileSystem.getDefaultReplication(Path path)
          Get the default replication.
 FileChecksum FilterFileSystem.getFileChecksum(Path f)
          Get the checksum of a file.
 FileChecksum HarFileSystem.getFileChecksum(Path f)
           
 FileChecksum FileSystem.getFileChecksum(Path f)
          Get the checksum of a file.
 FileStatus FilterFileSystem.getFileStatus(Path f)
          Get file status.
 FileStatus HarFileSystem.getFileStatus(Path f)
          return the filestatus of files in har archive.
 FileStatus RawLocalFileSystem.getFileStatus(Path f)
           
abstract  FileStatus FileSystem.getFileStatus(Path f)
          Return a file status object that represents the path.
static int HarFileSystem.getHarHash(Path p)
          the hash of the path p inside iniside the filesystem
 long FileSystem.getLength(Path f)
          Deprecated. Use getFileStatus() instead
 short FileSystem.getReplication(Path src)
          Deprecated. Use getFileStatus() instead
 FileStatus[] FileSystem.globStatus(Path pathPattern)
          Return all the files that match filePattern and are not checksum files.
 FileStatus[] FileSystem.globStatus(Path pathPattern, PathFilter filter)
          Return an array of FileStatus objects whose path names match pathPattern and is accepted by the user-supplied path filter.
static boolean ChecksumFileSystem.isChecksumFile(Path file)
          Return true iff file is a checksum file name.
 boolean FileSystem.isDirectory(Path f)
          Deprecated. Use getFileStatus() instead
 boolean FileSystem.isFile(Path f)
          True iff the named path is a regular file.
 FileStatus[] FilterFileSystem.listStatus(Path f)
          List files in a directory.
 FileStatus[] ChecksumFileSystem.listStatus(Path f)
          List the statuses of the files/directories in the given path if the path is a directory.
 FileStatus[] HarFileSystem.listStatus(Path f)
          liststatus returns the children of a directory after looking up the index files.
 FileStatus[] RawLocalFileSystem.listStatus(Path f)
           
abstract  FileStatus[] FileSystem.listStatus(Path f)
          List the statuses of the files/directories in the given path if the path is a directory.
 FileStatus[] FileSystem.listStatus(Path[] files)
          Filter files/directories in the given list of paths using default path filter.
 FileStatus[] FileSystem.listStatus(Path[] files, PathFilter filter)
          Filter files/directories in the given list of paths using user-supplied path filter.
 FileStatus[] FileSystem.listStatus(Path f, PathFilter filter)
          Filter files/directories in the given path using the user-supplied path filter.
 Path FilterFileSystem.makeQualified(Path path)
          Make sure that a path specifies a FileSystem.
 Path HarFileSystem.makeQualified(Path path)
           
 Path FileSystem.makeQualified(Path path)
          Make sure that a path specifies a FileSystem.
 Path Path.makeQualified(URI defaultUri, Path workingDir)
          Returns a qualified path object.
static boolean FileSystem.mkdirs(FileSystem fs, Path dir, FsPermission permission)
          create a directory with the provided permission The permission of the directory is set to be the provided permission as in setPermission, not permission&~umask
 boolean ChecksumFileSystem.mkdirs(Path f)
           
 boolean RawLocalFileSystem.mkdirs(Path f)
          Creates the specified directory hierarchy.
 boolean FileSystem.mkdirs(Path f)
          Call FileSystem.mkdirs(Path, FsPermission) with default permission.
 boolean FilterFileSystem.mkdirs(Path f, FsPermission permission)
          Make the given file and all non-existent parents into directories.
 boolean HarFileSystem.mkdirs(Path f, FsPermission permission)
          not implemented.
 boolean RawLocalFileSystem.mkdirs(Path f, FsPermission permission)
          Make the given file and all non-existent parents into directories.
abstract  boolean FileSystem.mkdirs(Path f, FsPermission permission)
          Make the given file and all non-existent parents into directories.
 void FileSystem.moveFromLocalFile(Path[] srcs, Path dst)
          The src files is on the local disk.
 void FileSystem.moveFromLocalFile(Path[] srcs, Path dst)
          The src files is on the local disk.
 void RawLocalFileSystem.moveFromLocalFile(Path src, Path dst)
           
 void FileSystem.moveFromLocalFile(Path src, Path dst)
          The src file is on the local disk.
 void FileSystem.moveToLocalFile(Path src, Path dst)
          The src file is under FS, and the dst is on the local disk.
 boolean Trash.moveToTrash(Path path)
          Move a file or directory to the current trash directory.
 FSDataInputStream FileSystem.open(Path f)
          Opens an FSDataInputStream at the indicated Path.
 FSDataInputStream FilterFileSystem.open(Path f, int bufferSize)
          Opens an FSDataInputStream at the indicated Path.
 FSDataInputStream ChecksumFileSystem.open(Path f, int bufferSize)
          Opens an FSDataInputStream at the indicated Path.
 FSDataInputStream HarFileSystem.open(Path f, int bufferSize)
          Returns a har input stream which fakes end of file.
 FSDataInputStream RawLocalFileSystem.open(Path f, int bufferSize)
           
abstract  FSDataInputStream FileSystem.open(Path f, int bufferSize)
          Opens an FSDataInputStream at the indicated Path.
 File RawLocalFileSystem.pathToFile(Path path)
          Convert a path to a File.
 File LocalFileSystem.pathToFile(Path path)
          Convert a path to a File.
 boolean FilterFileSystem.rename(Path src, Path dst)
          Renames Path src to Path dst.
 boolean ChecksumFileSystem.rename(Path src, Path dst)
          Rename files/dirs
 boolean RawLocalFileSystem.rename(Path src, Path dst)
           
abstract  boolean FileSystem.rename(Path src, Path dst)
          Renames Path src to Path dst.
 boolean ChecksumFileSystem.reportChecksumFailure(Path f, FSDataInputStream in, long inPos, FSDataInputStream sums, long sumsPos)
          Report a checksum error to the file system.
 boolean LocalFileSystem.reportChecksumFailure(Path p, FSDataInputStream in, long inPos, FSDataInputStream sums, long sumsPos)
          Moves files to a bad file directory on the same device, so that their storage will not be reused.
 boolean InMemoryFileSystem.reserveSpaceWithCheckSum(Path f, long size)
          Deprecated. Register a file with its size.
 void FilterFileSystem.setOwner(Path p, String username, String groupname)
          Set owner of a path (i.e.
 void HarFileSystem.setOwner(Path p, String username, String groupname)
          not implemented.
 void RawLocalFileSystem.setOwner(Path p, String username, String groupname)
          Use the command chown to set owner.
 void FileSystem.setOwner(Path p, String username, String groupname)
          Set owner of a path (i.e.
 void FilterFileSystem.setPermission(Path p, FsPermission permission)
          Set permission of a path.
 void HarFileSystem.setPermission(Path p, FsPermission permisssion)
          Not implemented.
 void RawLocalFileSystem.setPermission(Path p, FsPermission permission)
          Use the command chmod to set permission.
 void FileSystem.setPermission(Path p, FsPermission permission)
          Set permission of a path.
 boolean FilterFileSystem.setReplication(Path src, short replication)
          Set replication for an existing file.
 boolean ChecksumFileSystem.setReplication(Path src, short replication)
          Set replication for an existing file.
 boolean HarFileSystem.setReplication(Path src, short replication)
          Not implemented.
 boolean FileSystem.setReplication(Path src, short replication)
          Set replication for an existing file.
 void FileSystem.setTimes(Path p, long mtime, long atime)
          Set access time of a file
 void FilterFileSystem.setWorkingDirectory(Path newDir)
          Set the current working directory for the given file system.
 void HarFileSystem.setWorkingDirectory(Path newDir)
           
 void RawLocalFileSystem.setWorkingDirectory(Path newDir)
          Set the working directory to the given directory.
abstract  void FileSystem.setWorkingDirectory(Path new_dir)
          Set the current working directory for the given file system.
 Path FilterFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          Returns a local File that the user can write output to.
 Path ChecksumFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 Path HarFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          not implemented.
 Path RawLocalFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 Path FileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
          Returns a local File that the user can write output to.
static Path[] FileUtil.stat2Paths(FileStatus[] stats, Path path)
          convert an array of FileStatus to an array of Path.
 

Constructors in org.apache.hadoop.fs with parameters of type Path
FileStatus(long length, boolean isdir, int block_replication, long blocksize, long modification_time, long access_time, FsPermission permission, String owner, String group, Path path)
           
FileStatus(long length, boolean isdir, int block_replication, long blocksize, long modification_time, Path path)
           
FSInputChecker(Path file, int numOfRetries)
          Constructor
FSInputChecker(Path file, int numOfRetries, boolean verifyChecksum, Checksum sum, int chunkSize, int checksumSize)
          Constructor
Path(Path parent, Path child)
          Resolve a child path against a parent path.
Path(Path parent, String child)
          Resolve a child path against a parent path.
Path(String parent, Path child)
          Resolve a child path against a parent path.
 

Uses of Path in org.apache.hadoop.fs.ftp
 

Methods in org.apache.hadoop.fs.ftp that return Path
 Path FTPFileSystem.getHomeDirectory()
           
 Path FTPFileSystem.getWorkingDirectory()
           
 

Methods in org.apache.hadoop.fs.ftp with parameters of type Path
 FSDataOutputStream FTPFileSystem.append(Path f, int bufferSize, Progressable progress)
          This optional operation is not yet supported.
 FSDataOutputStream FTPFileSystem.create(Path file, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
          A stream obtained via this call must be closed before using other APIs of this class or else the invocation will block.
 boolean FTPFileSystem.delete(Path file)
          Deprecated. Use delete(Path, boolean) instead
 boolean FTPFileSystem.delete(Path file, boolean recursive)
           
 FileStatus FTPFileSystem.getFileStatus(Path file)
           
 FileStatus[] FTPFileSystem.listStatus(Path file)
           
 boolean FTPFileSystem.mkdirs(Path file, FsPermission permission)
           
 FSDataInputStream FTPFileSystem.open(Path file, int bufferSize)
           
 boolean FTPFileSystem.rename(Path src, Path dst)
           
 void FTPFileSystem.setWorkingDirectory(Path newDir)
           
 

Uses of Path in org.apache.hadoop.fs.kfs
 

Methods in org.apache.hadoop.fs.kfs that return Path
 Path KosmosFileSystem.getWorkingDirectory()
           
 Path KosmosFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 

Methods in org.apache.hadoop.fs.kfs with parameters of type Path
 FSDataOutputStream KosmosFileSystem.append(Path f, int bufferSize, Progressable progress)
          This optional operation is not yet supported.
 void KosmosFileSystem.completeLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 void KosmosFileSystem.copyFromLocalFile(boolean delSrc, Path src, Path dst)
           
 void KosmosFileSystem.copyToLocalFile(boolean delSrc, Path src, Path dst)
           
 FSDataOutputStream KosmosFileSystem.create(Path file, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
           
 boolean KosmosFileSystem.delete(Path path)
          Deprecated. 
 boolean KosmosFileSystem.delete(Path path, boolean recursive)
           
 FileStatus KosmosFileSystem.getFileStatus(Path path)
           
 long KosmosFileSystem.getLength(Path path)
          Deprecated. 
 short KosmosFileSystem.getReplication(Path path)
          Deprecated. 
 boolean KosmosFileSystem.isDirectory(Path path)
          Deprecated. 
 boolean KosmosFileSystem.isFile(Path path)
          Deprecated. 
 FileStatus[] KosmosFileSystem.listStatus(Path path)
           
 void KosmosFileSystem.lock(Path path, boolean shared)
          Deprecated. 
 boolean KosmosFileSystem.mkdirs(Path path, FsPermission permission)
           
 FSDataInputStream KosmosFileSystem.open(Path path, int bufferSize)
           
 void KosmosFileSystem.release(Path path)
          Deprecated. 
 boolean KosmosFileSystem.rename(Path src, Path dst)
           
 boolean KosmosFileSystem.setReplication(Path path, short replication)
           
 void KosmosFileSystem.setWorkingDirectory(Path dir)
           
 Path KosmosFileSystem.startLocalOutput(Path fsOutputFile, Path tmpLocalFile)
           
 

Uses of Path in org.apache.hadoop.fs.s3
 

Methods in org.apache.hadoop.fs.s3 that return Path
 Path S3FileSystem.getWorkingDirectory()
           
 

Methods in org.apache.hadoop.fs.s3 that return types with arguments of type Path
 Set<Path> FileSystemStore.listDeepSubPaths(Path path)
           
 Set<Path> FileSystemStore.listSubPaths(Path path)
           
 

Methods in org.apache.hadoop.fs.s3 with parameters of type Path
 FSDataOutputStream S3FileSystem.append(Path f, int bufferSize, Progressable progress)
          This optional operation is not yet supported.
 FSDataOutputStream S3FileSystem.create(Path file, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
           
 boolean S3FileSystem.delete(Path path)
          Deprecated. 
 boolean S3FileSystem.delete(Path path, boolean recursive)
           
 void FileSystemStore.deleteINode(Path path)
           
 FileStatus S3FileSystem.getFileStatus(Path f)
          FileStatus for S3 file systems.
 boolean FileSystemStore.inodeExists(Path path)
           
 boolean S3FileSystem.isFile(Path path)
           
 Set<Path> FileSystemStore.listDeepSubPaths(Path path)
           
 FileStatus[] S3FileSystem.listStatus(Path f)
           
 Set<Path> FileSystemStore.listSubPaths(Path path)
           
 boolean S3FileSystem.mkdirs(Path path, FsPermission permission)
           
 FSDataInputStream S3FileSystem.open(Path path, int bufferSize)
           
 boolean S3FileSystem.rename(Path src, Path dst)
           
 INode FileSystemStore.retrieveINode(Path path)
           
 void S3FileSystem.setWorkingDirectory(Path dir)
           
 void FileSystemStore.storeINode(Path path, INode inode)
           
 

Uses of Path in org.apache.hadoop.fs.s3native
 

Methods in org.apache.hadoop.fs.s3native that return Path
 Path NativeS3FileSystem.getWorkingDirectory()
           
 

Methods in org.apache.hadoop.fs.s3native with parameters of type Path
 FSDataOutputStream NativeS3FileSystem.append(Path f, int bufferSize, Progressable progress)
          This optional operation is not yet supported.
 FSDataOutputStream NativeS3FileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress)
           
 boolean NativeS3FileSystem.delete(Path path)
          Deprecated. 
 boolean NativeS3FileSystem.delete(Path f, boolean recurse)
           
 FileStatus NativeS3FileSystem.getFileStatus(Path f)
           
 FileStatus[] NativeS3FileSystem.listStatus(Path f)
           If f is a file, this method will make a single call to S3.
 boolean NativeS3FileSystem.mkdirs(Path f, FsPermission permission)
           
 FSDataInputStream NativeS3FileSystem.open(Path f, int bufferSize)
           
 boolean NativeS3FileSystem.rename(Path src, Path dst)
           
 void NativeS3FileSystem.setWorkingDirectory(Path newDir)
          Set the working directory to the given directory.
 

Uses of Path in org.apache.hadoop.fs.shell
 

Methods in org.apache.hadoop.fs.shell with parameters of type Path
protected abstract  void Command.run(Path path)
          Execute the command on the input path
protected  void Count.run(Path path)
           
 

Uses of Path in org.apache.hadoop.io
 

Methods in org.apache.hadoop.io with parameters of type Path
 SequenceFile.Writer SequenceFile.Sorter.cloneFileAttributes(Path inputFile, Path outputFile, Progressable prog)
          Clones the attributes (like compression of the input file and creates a corresponding Writer
protected  SequenceFile.Reader MapFile.Reader.createDataFileReader(FileSystem fs, Path dataFile, Configuration conf)
          Override this method to specialize the type of SequenceFile.Reader returned.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, boolean createParent, SequenceFile.CompressionType compressionType, CompressionCodec codec, SequenceFile.Metadata metadata)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, SequenceFile.Metadata metadata)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, SequenceFile.Metadata metadata)
          Construct the preferred type of SequenceFile Writer.
static SequenceFile.Writer SequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, Progressable progress)
          Construct the preferred type of SequenceFile Writer.
static long MapFile.fix(FileSystem fs, Path dir, Class<? extends Writable> keyClass, Class<? extends Writable> valueClass, boolean dryrun, Configuration conf)
          This method attempts to fix a corrupt MapFile by re-creating its index.
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(List<SequenceFile.Sorter.SegmentDescriptor> segments, Path tmpDir)
          Merges the list of segments of type SegmentDescriptor
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(Path[] inNames, boolean deleteInputs, int factor, Path tmpDir)
          Merges the contents of files passed in Path[]
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(Path[] inNames, boolean deleteInputs, int factor, Path tmpDir)
          Merges the contents of files passed in Path[]
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(Path[] inNames, boolean deleteInputs, Path tmpDir)
          Merges the contents of files passed in Path[] using a max factor value that is already set
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(Path[] inNames, boolean deleteInputs, Path tmpDir)
          Merges the contents of files passed in Path[] using a max factor value that is already set
 void SequenceFile.Sorter.merge(Path[] inFiles, Path outFile)
          Merge the provided files.
 void SequenceFile.Sorter.merge(Path[] inFiles, Path outFile)
          Merge the provided files.
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(Path[] inNames, Path tempDir, boolean deleteInputs)
          Merges the contents of files passed in Path[]
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.merge(Path[] inNames, Path tempDir, boolean deleteInputs)
          Merges the contents of files passed in Path[]
protected  FSDataInputStream SequenceFile.Reader.openFile(FileSystem fs, Path file, int bufferSize, long length)
          Override this method to specialize the type of FSDataInputStream returned.
 void SequenceFile.Sorter.sort(Path[] inFiles, Path outFile, boolean deleteInput)
          Perform a file sort from a set of input files into an output file.
 void SequenceFile.Sorter.sort(Path[] inFiles, Path outFile, boolean deleteInput)
          Perform a file sort from a set of input files into an output file.
 void SequenceFile.Sorter.sort(Path inFile, Path outFile)
          The backwards compatible interface to sort.
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.sortAndIterate(Path[] inFiles, Path tempDir, boolean deleteInput)
          Perform a file sort from a set of input files and return an iterator.
 SequenceFile.Sorter.RawKeyValueIterator SequenceFile.Sorter.sortAndIterate(Path[] inFiles, Path tempDir, boolean deleteInput)
          Perform a file sort from a set of input files and return an iterator.
 

Constructors in org.apache.hadoop.io with parameters of type Path
SequenceFile.Reader(FileSystem fs, Path file, Configuration conf)
          Open the named file.
SequenceFile.Sorter.SegmentDescriptor(long segmentOffset, long segmentLength, Path segmentPathName)
          Constructs a segment
SequenceFile.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass)
          Create the named file.
SequenceFile.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, Progressable progress, SequenceFile.Metadata metadata)
          Create the named file with write-progress reporter.
SequenceFile.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, Progressable progress, SequenceFile.Metadata metadata)
          Create the named file with write-progress reporter.
 

Uses of Path in org.apache.hadoop.io.compress
 

Methods in org.apache.hadoop.io.compress with parameters of type Path
 CompressionCodec CompressionCodecFactory.getCodec(Path file)
          Find the relevant compression codec for the given file based on its filename suffix.
 

Uses of Path in org.apache.hadoop.mapred
 

Fields in org.apache.hadoop.mapred declared as Path
protected static Path JobHistory.DONE
           
 

Methods in org.apache.hadoop.mapred that return Path
 Path JobLocalizer.findCredentials()
           
static Path[] FileInputFormat.getInputPaths(JobConf conf)
          Get the list of input Paths for the map-reduce job.
static Path JobHistory.JobInfo.getJobHistoryLogLocation(String logFileName)
          Get the job history file path given the history filename
static Path JobHistory.JobInfo.getJobHistoryLogLocationForUser(String logFileName, JobConf jobConf)
          Get the user job history file path
 Path JobConf.getLocalPath(String pathString)
          Constructs a local file name.
static Path FileOutputFormat.getOutputPath(JobConf conf)
          Get the Path to the output directory for the map-reduce job.
 Path FileSplit.getPath()
          The file containing this split's data.
static Path FileOutputFormat.getPathForCustomFile(JobConf conf, String name)
          Helper function to generate a Path for a file that is unique for the task within the job output directory.
static Path SkipBadRecords.getSkipOutputPath(Configuration conf)
          Get the directory to which skipped records are written.
 Path JobClient.getStagingAreaDir()
          Grab the jobtracker's view of the staging directory path where job-specific files will be placed.
 Path JobClient.getSystemDir()
          Grab the jobtracker system directory path where job-specific files are to be placed.
static Path FileOutputFormat.getTaskOutputPath(JobConf conf, String name)
          Helper function to create the task's temporary output directory and return the path to the task's output file.
 Path JobConf.getWorkingDirectory()
          Get the current working directory for the default file system.
static Path FileOutputFormat.getWorkOutputPath(JobConf conf)
          Get the Path to the task's temporary output directory for the map-reduce job

Tasks' Side-Effect Files

static Path JobHistory.JobInfo.recoverJobHistoryFile(JobConf conf, Path logFilePath)
          Selects one of the two files generated as a part of recovery.
 

Methods in org.apache.hadoop.mapred with parameters of type Path
 boolean OutputLogFilter.accept(Path path)
          Deprecated.  
 boolean Utils.OutputFileUtils.OutputFilesFilter.accept(Path path)
           
 boolean Utils.OutputFileUtils.OutputLogFilter.accept(Path path)
           
static void FileInputFormat.addInputPath(JobConf conf, Path path)
          Add a Path to the list of inputs for the map-reduce job.
protected static FileSystem.Statistics Task.getFsStatistics(Path path, Configuration conf)
          Gets a handle to the Statistics instance based on the scheme associated with path.
static SequenceFile.Reader[] SequenceFileOutputFormat.getReaders(Configuration conf, Path dir)
          Open the output generated by this format.
static MapFile.Reader[] MapFileOutputFormat.getReaders(FileSystem ignored, Path dir, Configuration conf)
          Open the output generated by this format.
abstract  void TaskController.initializeJob(String user, String jobid, Path credentials, Path jobConf, TaskUmbilicalProtocol taskTracker, InetSocketAddress ttAddr)
          Create all of the directories necessary for the job to start and download all of the job and private distributed cache files.
 void DefaultTaskController.initializeJob(String user, String jobid, Path credentials, Path jobConf, TaskUmbilicalProtocol taskTracker, InetSocketAddress ttAddr)
          This routine initializes the local file system for running a job.
static boolean JobClient.isJobDirValid(Path jobDirPath, FileSystem fs)
          Checks if the job directory is clean and has all the required components for (re) starting the job
protected  boolean TextInputFormat.isSplitable(FileSystem fs, Path file)
           
protected  boolean FileInputFormat.isSplitable(FileSystem fs, Path filename)
          Is the given filename splitable? Usually, true, but if the file is stream compressed, it will not be.
protected  boolean KeyValueTextInputFormat.isSplitable(FileSystem fs, Path file)
           
 void JobLocalizer.localizeJobFiles(JobID jobid, JobConf jConf, Path localJobFile, Path localJobTokenFile, TaskUmbilicalProtocol taskTracker)
           
 void JobLocalizer.localizeJobFiles(JobID jobid, JobConf jConf, Path localJobTokenFile, TaskUmbilicalProtocol taskTracker)
           
static Path JobHistory.JobInfo.recoverJobHistoryFile(JobConf conf, Path logFilePath)
          Selects one of the two files generated as a part of recovery.
 int JobLocalizer.runSetup(String user, String jobid, Path localJobTokenFile, TaskUmbilicalProtocol taskTracker)
           
static void FileInputFormat.setInputPaths(JobConf conf, Path... inputPaths)
          Set the array of Paths as the list of inputs for the map-reduce job.
static void FileOutputFormat.setOutputPath(JobConf conf, Path outputDir)
          Set the Path of the output directory for the map-reduce job.
static void SkipBadRecords.setSkipOutputPath(JobConf conf, Path path)
          Set the directory to which skipped records are written.
 void JobConf.setWorkingDirectory(Path dir)
          Set the current working directory for the default file system.
protected static String TaskController.writeCommand(String cmdLine, FileSystem fs, Path commandFile)
           
static void JobLocalizer.writeLocalJobFile(Path jobFile, JobConf conf)
          Write the task specific job-configuration file.
 

Constructors in org.apache.hadoop.mapred with parameters of type Path
FileSplit(Path file, long start, long length, JobConf conf)
          Deprecated.  
FileSplit(Path file, long start, long length, String[] hosts)
          Constructs a split with host information
JobConf(Path config)
          Construct a map/reduce configuration.
MultiFileSplit(JobConf job, Path[] files, long[] lengths)
          Deprecated.  
 

Uses of Path in org.apache.hadoop.mapred.join
 

Methods in org.apache.hadoop.mapred.join with parameters of type Path
static String CompositeInputFormat.compose(String op, Class<? extends InputFormat> inf, Path... path)
          Convenience method for constructing composite formats.
 

Uses of Path in org.apache.hadoop.mapred.lib
 

Methods in org.apache.hadoop.mapred.lib that return Path
 Path CombineFileSplit.getPath(int i)
          Returns the ith Path
 Path[] CombineFileSplit.getPaths()
          Returns all the Paths in the split
 

Methods in org.apache.hadoop.mapred.lib with parameters of type Path
static void MultipleInputs.addInputPath(JobConf conf, Path path, Class<? extends InputFormat> inputFormatClass)
          Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
static void MultipleInputs.addInputPath(JobConf conf, Path path, Class<? extends InputFormat> inputFormatClass, Class<? extends Mapper> mapperClass)
          Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
protected static FileSplit NLineInputFormat.createFileSplit(Path fileName, long begin, long length)
          NLineInputFormat uses LineRecordReader, which always reads (and consumes) at least one character out of its upper split boundary.
static void TotalOrderPartitioner.setPartitionFile(JobConf job, Path p)
          Set the path to the SequenceFile storing the sorted partition keyset.
 

Constructors in org.apache.hadoop.mapred.lib with parameters of type Path
CombineFileSplit(JobConf job, Path[] files, long[] lengths)
           
CombineFileSplit(JobConf job, Path[] files, long[] start, long[] lengths, String[] locations)
           
 

Uses of Path in org.apache.hadoop.mapreduce
 

Methods in org.apache.hadoop.mapreduce that return Path
static Path JobSubmissionFiles.getJobConfPath(Path jobSubmitDir)
          Get the job conf path.
static Path JobSubmissionFiles.getJobDistCacheArchives(Path jobSubmitDir)
          Get the job distributed cache archives path.
static Path JobSubmissionFiles.getJobDistCacheFiles(Path jobSubmitDir)
          Get the job distributed cache files path.
static Path JobSubmissionFiles.getJobDistCacheLibjars(Path jobSubmitDir)
          Get the job distributed cache libjars path.
static Path JobSubmissionFiles.getJobJar(Path jobSubmitDir)
          Get the job jar path.
static Path JobSubmissionFiles.getJobSplitFile(Path jobSubmissionDir)
           
static Path JobSubmissionFiles.getJobSplitMetaFile(Path jobSubmissionDir)
           
static Path JobSubmissionFiles.getStagingDir(JobClient client, Configuration conf)
          Initializes the staging directory and returns the path.
 Path JobContext.getWorkingDirectory()
          Get the current working directory for the default file system.
 

Methods in org.apache.hadoop.mapreduce with parameters of type Path
static Path JobSubmissionFiles.getJobConfPath(Path jobSubmitDir)
          Get the job conf path.
static Path JobSubmissionFiles.getJobDistCacheArchives(Path jobSubmitDir)
          Get the job distributed cache archives path.
static Path JobSubmissionFiles.getJobDistCacheFiles(Path jobSubmitDir)
          Get the job distributed cache files path.
static Path JobSubmissionFiles.getJobDistCacheLibjars(Path jobSubmitDir)
          Get the job distributed cache libjars path.
static Path JobSubmissionFiles.getJobJar(Path jobSubmitDir)
          Get the job jar path.
static Path JobSubmissionFiles.getJobSplitFile(Path jobSubmissionDir)
           
static Path JobSubmissionFiles.getJobSplitMetaFile(Path jobSubmissionDir)
           
 void Job.setWorkingDirectory(Path dir)
          Set the current working directory for the default file system.
 

Uses of Path in org.apache.hadoop.mapreduce.lib.input
 

Methods in org.apache.hadoop.mapreduce.lib.input that return Path
static Path[] FileInputFormat.getInputPaths(JobContext context)
          Get the list of input Paths for the map-reduce job.
 Path FileSplit.getPath()
          The file containing this split's data.
 Path CombineFileSplit.getPath(int i)
          Returns the ith Path
 Path[] CombineFileSplit.getPaths()
          Returns all the Paths in the split
 

Methods in org.apache.hadoop.mapreduce.lib.input with parameters of type Path
static void FileInputFormat.addInputPath(Job job, Path path)
          Add a Path to the list of inputs for the map-reduce job.
static void MultipleInputs.addInputPath(Job job, Path path, Class<? extends InputFormat> inputFormatClass)
          Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
static void MultipleInputs.addInputPath(Job job, Path path, Class<? extends InputFormat> inputFormatClass, Class<? extends Mapper> mapperClass)
          Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
protected static FileSplit NLineInputFormat.createFileSplit(Path fileName, long begin, long length)
          NLineInputFormat uses LineRecordReader, which always reads (and consumes) at least one character out of its upper split boundary.
protected  boolean CombineFileInputFormat.isSplitable(JobContext context, Path file)
           
protected  boolean TextInputFormat.isSplitable(JobContext context, Path file)
           
protected  boolean FileInputFormat.isSplitable(JobContext context, Path filename)
          Is the given filename splitable? Usually, true, but if the file is stream compressed, it will not be.
protected  boolean KeyValueTextInputFormat.isSplitable(JobContext context, Path file)
           
static void FileInputFormat.setInputPaths(Job job, Path... inputPaths)
          Set the array of Paths as the list of inputs for the map-reduce job.
 

Constructors in org.apache.hadoop.mapreduce.lib.input with parameters of type Path
CombineFileSplit(Path[] files, long[] lengths)
           
CombineFileSplit(Path[] files, long[] start, long[] lengths, String[] locations)
           
FileSplit(Path file, long start, long length, String[] hosts)
          Constructs a split with host information
 

Uses of Path in org.apache.hadoop.mapreduce.lib.output
 

Methods in org.apache.hadoop.mapreduce.lib.output that return Path
 Path FileOutputFormat.getDefaultWorkFile(TaskAttemptContext context, String extension)
          Get the default path and filename for the output format.
static Path FileOutputFormat.getOutputPath(JobContext job)
          Get the Path to the output directory for the map-reduce job.
static Path FileOutputFormat.getPathForWorkFile(TaskInputOutputContext<?,?,?,?> context, String name, String extension)
          Helper function to generate a Path for a file that is unique for the task within the job output directory.
static Path FileOutputFormat.getWorkOutputPath(TaskInputOutputContext<?,?,?,?> context)
          Get the Path to the task's temporary output directory for the map-reduce job

Tasks' Side-Effect Files

 Path FileOutputCommitter.getWorkPath()
          Get the directory that the task should write results into
 

Methods in org.apache.hadoop.mapreduce.lib.output with parameters of type Path
static void FileOutputFormat.setOutputPath(Job job, Path outputDir)
          Set the Path of the output directory for the map-reduce job.
 

Constructors in org.apache.hadoop.mapreduce.lib.output with parameters of type Path
FileOutputCommitter(Path outputPath, TaskAttemptContext context)
          Create a file output committer
 

Uses of Path in org.apache.hadoop.mapreduce.lib.partition
 

Methods in org.apache.hadoop.mapreduce.lib.partition with parameters of type Path
static void TotalOrderPartitioner.setPartitionFile(Configuration conf, Path p)
          Set the path to the SequenceFile storing the sorted partition keyset.
 

Uses of Path in org.apache.hadoop.mapreduce.security
 

Methods in org.apache.hadoop.mapreduce.security with parameters of type Path
static void TokenCache.obtainTokensForNamenodes(Credentials credentials, Path[] ps, Configuration conf)
          Convenience method to obtain delegation tokens from namenodes corresponding to the paths passed.
 

Uses of Path in org.apache.hadoop.mapreduce.split
 

Methods in org.apache.hadoop.mapreduce.split with parameters of type Path
static void JobSplitWriter.createSplitFiles(Path jobSubmitDir, Configuration conf, FileSystem fs, InputSplit[] splits)
           
static
<T extends InputSplit>
void
JobSplitWriter.createSplitFiles(Path jobSubmitDir, Configuration conf, FileSystem fs, List<InputSplit> splits)
           
static
<T extends InputSplit>
void
JobSplitWriter.createSplitFiles(Path jobSubmitDir, Configuration conf, FileSystem fs, T[] splits)
           
static JobSplit.TaskSplitMetaInfo[] SplitMetaInfoReader.readSplitMetaInfo(JobID jobId, FileSystem fs, Configuration conf, Path jobSubmitDir)
           
 

Uses of Path in org.apache.hadoop.security
 

Methods in org.apache.hadoop.security with parameters of type Path
static Credentials Credentials.readTokenStorageFile(Path filename, Configuration conf)
          Convenience method for reading a token storage file, and loading the Tokens therein in the passed UGI
 void Credentials.writeTokenStorageFile(Path filename, Configuration conf)
           
 

Uses of Path in org.apache.hadoop.util
 

Methods in org.apache.hadoop.util that return Path
static Path[] StringUtils.stringToPath(String[] str)
           
 

Methods in org.apache.hadoop.util with parameters of type Path
static void DiskChecker.checkDir(LocalFileSystem localFS, Path dir, FsPermission expected)
          Create the local directory if necessary, check permissions and also ensure it can be read from and written into.
static boolean DiskChecker.mkdirsWithExistsAndPermissionCheck(LocalFileSystem localFS, Path dir, FsPermission expected)
          Create the directory or check permissions if it already exists.
 



Copyright © 2009 The Apache Software Foundation