Uses of Class
org.apache.hadoop.fs.FileSystem
Packages that use FileSystem
Package
Description
Implementations of
AbstractFileSystem for hdfs
over rpc and hdfs over web.Supporting classes for metrics instrumentation.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
This package contains implementation classes for use inside
filesystems.
ViewFileSystem and ViewFileSystemOverloadScheme classes.
Generic i/o code for use when reading and writing data to the network,
to databases, and to files.
Support for dynamic access to filesystem operations which are not available
in older hadoop releases.
Persistence formats.
Builtin metrics sinks
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of FileSystem in org.apache.hadoop.fs
Subclasses of FileSystem in org.apache.hadoop.fsModifier and TypeClassDescriptionclassAbstract Checksumed FileSystem.classAFilterFileSystemcontains some other file system, which it uses as its basic file system, possibly transforming the data along the way or providing additional functionality.classImplement the FileSystem API for the checksumed local filesystem.classImplement the FileSystem API for the raw local filesystem.Fields in org.apache.hadoop.fs declared as FileSystemModifier and TypeFieldDescriptionprotected FileSystemFilterFileSystem.fsprotected FileSystemTrashPolicy.fsMethods in org.apache.hadoop.fs that return FileSystemModifier and TypeMethodDescriptionstatic FileSystemFileSystem.get(URI uri, Configuration conf) Get a FileSystem for this URI's scheme and authority.static FileSystemFileSystem.get(URI uri, Configuration conf, String user) Get a FileSystem instance based on the uri, the passed in configuration and the user.static FileSystemFileSystem.get(Configuration conf) Returns the configured FileSystem implementation.FileSystem.getChildFileSystems()Get all the immediate child FileSystems embedded in this FileSystem.FilterFileSystem.getChildFileSystems()Path.getFileSystem(Configuration conf) Return the FileSystem that owns this Path.protected FileSystemFSDataOutputStreamBuilder.getFS()protected static FileSystemFileSystem.getFSofPath(Path absOrFqPath, Configuration conf) static FileSystemFileSystem.getNamed(String name, Configuration conf) Deprecated.LocalFileSystem.getRaw()ChecksumFileSystem.getRawFileSystem()get the raw file systemFilterFileSystem.getRawFileSystem()Get the raw file systemstatic FileSystemFileSystem.newInstance(URI uri, Configuration config) Returns the FileSystem for this URI's scheme and authority.static FileSystemFileSystem.newInstance(URI uri, Configuration conf, String user) Returns the FileSystem for this URI's scheme and authority and the given user.static FileSystemFileSystem.newInstance(Configuration conf) Returns a unique configured FileSystem implementation for the default filesystem of the supplied configuration.static FileSystemFileUtil.write(FileSystem fs, Path path, byte[] bytes) Writes bytes to a file.static FileSystemFileUtil.write(FileSystem fs, Path path, CharSequence charseq) Write a line of text to a file.static FileSystemFileUtil.write(FileSystem fs, Path path, CharSequence charseq, Charset cs) Write a line of text to a file.static FileSystemFileUtil.write(FileSystem fs, Path path, Iterable<? extends CharSequence> lines, Charset cs) Write lines of text to a file.Methods in org.apache.hadoop.fs that return types with arguments of type FileSystemModifier and TypeMethodDescriptionstatic Class<? extends FileSystem>FileSystem.getFileSystemClass(String scheme, Configuration conf) Get the FileSystem implementation class of a filesystem.Methods in org.apache.hadoop.fs with parameters of type FileSystemModifier and TypeMethodDescriptionstatic booleanFileUtil.checkFSSupportsEC(FileSystem fs, Path path) Return true if the FS implementsWithErasureCodingand supports EC_POLICY option inOptions.OpenFileOptions.static booleanFileUtil.compareFs(FileSystem srcFs, FileSystem destFs) static booleanFileUtil.copy(File src, FileSystem dstFS, Path dst, boolean deleteSource, Configuration conf) Copy local files to a FileSystem.static booleanFileUtil.copy(FileSystem srcFS, FileStatus srcStatus, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf) Copy a file/directory tree within/between filesystems.static booleanFileUtil.copy(FileSystem srcFS, Path[] srcs, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf) static booleanFileUtil.copy(FileSystem srcFS, Path src, File dst, boolean deleteSource, Configuration conf) Copy FileSystem files to local files.static booleanFileUtil.copy(FileSystem srcFS, Path src, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf) Copy files between FileSystems.static booleanFileUtil.copy(FileSystem srcFS, Path src, FileSystem dstFS, Path dst, boolean deleteSource, Configuration conf) Copy files between FileSystems.static FSDataOutputStreamFileSystem.create(FileSystem fs, Path file, FsPermission permission) Create a file with the provided permission.protected static org.apache.hadoop.fs.FileSystem.FSDataInputStreamBuilderFileSystem.createDataInputStreamBuilder(FileSystem fileSystem, Path path) Create instance of the standardFileSystem.FSDataInputStreamBuilderfor the given filesystem and path.protected static org.apache.hadoop.fs.FileSystem.FSDataInputStreamBuilderFileSystem.createDataInputStreamBuilder(FileSystem fileSystem, PathHandle pathHandle) Create instance of the standardFileSystem.FSDataInputStreamBuilderfor the given filesystem and path handle.protected static FSDataOutputStreamBuilderFileSystem.createDataOutputStreamBuilder(FileSystem fileSystem, Path path) Create instance of the standard FSDataOutputStreamBuilder for the given filesystem and path.static voidFileUtil.fullyDelete(FileSystem fs, Path dir) Deprecated.static TrashPolicyTrashPolicy.getInstance(Configuration conf, FileSystem fs) Get an instance of the configured TrashPolicy based on the value of the configuration parameter fs.trash.classname.static TrashPolicyTrashPolicy.getInstance(Configuration conf, FileSystem fs, Path home) Deprecated.UseTrashPolicy.getInstance(Configuration, FileSystem)instead.voidTrashPolicy.initialize(Configuration conf, FileSystem fs) Used to setup the trash policy.abstract voidTrashPolicy.initialize(Configuration conf, FileSystem fs, Path home) Deprecated.UseTrashPolicy.initialize(Configuration, FileSystem)instead.Path.makeQualified(FileSystem fs) Deprecated.usePath.makeQualified(URI, Path)static voidFileUtil.maybeIgnoreMissingDirectory(FileSystem fs, Path path, FileNotFoundException e) Method to call after a FNFE has been raised on a treewalk, so as to decide whether to throw the exception (default), or, if the FS supports inconsistent directory listings, to log and ignore it.static booleanFileSystem.mkdirs(FileSystem fs, Path dir, FsPermission permission) Create a directory with the provided permission.static booleanTrash.moveToAppropriateTrash(FileSystem fs, Path p, Configuration conf) In case of the symlinks or mount points, one has to move the appropriate trashbin in the actual volume of the path p being deleted.static voidFileUtil.rename(FileSystem srcFs, Path src, Path dst, Options.Rename... options) static FileSystemFileUtil.write(FileSystem fs, Path path, byte[] bytes) Writes bytes to a file.static FileSystemFileUtil.write(FileSystem fs, Path path, CharSequence charseq) Write a line of text to a file.static FileSystemFileUtil.write(FileSystem fs, Path path, CharSequence charseq, Charset cs) Write a line of text to a file.static FileSystemFileUtil.write(FileSystem fs, Path path, Iterable<? extends CharSequence> lines, Charset cs) Write lines of text to a file.Method parameters in org.apache.hadoop.fs with type arguments of type FileSystemModifier and TypeMethodDescriptionstatic org.apache.hadoop.fs.FileSystem.StatisticsFileSystem.getStatistics(String scheme, Class<? extends FileSystem> cls) Deprecated.Constructors in org.apache.hadoop.fs with parameters of type FileSystemModifierConstructorDescriptionprotectedFSDataOutputStreamBuilder(FileSystem fileSystem, Path p) Constructor.LocalFileSystem(FileSystem rawLocalFileSystem) Trash(FileSystem fs, Configuration conf) Construct a trash can accessor for the FileSystem provided. -
Uses of FileSystem in org.apache.hadoop.fs.adl
Subclasses of FileSystem in org.apache.hadoop.fs.adlModifier and TypeClassDescriptionclassA FileSystem to access Azure Data Lake Store. -
Uses of FileSystem in org.apache.hadoop.fs.azure
Subclasses of FileSystem in org.apache.hadoop.fs.azure -
Uses of FileSystem in org.apache.hadoop.fs.ftp
Subclasses of FileSystem in org.apache.hadoop.fs.ftpModifier and TypeClassDescriptionclassAFileSystembacked by an FTP client provided by Apache Commons Net. -
Uses of FileSystem in org.apache.hadoop.fs.impl
Methods in org.apache.hadoop.fs.impl that return FileSystemModifier and TypeMethodDescriptionprotected FileSystemFutureDataInputStreamBuilderImpl.getFS()protected FileSystemMultipartUploaderBuilderImpl.getFS()Constructors in org.apache.hadoop.fs.impl with parameters of type FileSystemModifierConstructorDescriptionprotectedFutureDataInputStreamBuilderImpl(FileSystem fileSystem, Path path) Constructor.FutureDataInputStreamBuilderImpl(FileSystem fileSystem, PathHandle pathHandle) Constructor with PathHandle.protectedMultipartUploaderBuilderImpl(FileSystem fileSystem, Path p) Constructor. -
Uses of FileSystem in org.apache.hadoop.fs.viewfs
Subclasses of FileSystem in org.apache.hadoop.fs.viewfsModifier and TypeClassDescriptionclassViewFileSystem (extends the FileSystem interface) implements a client-side mount table.Methods in org.apache.hadoop.fs.viewfs that return FileSystemMethods in org.apache.hadoop.fs.viewfs with parameters of type FileSystemModifier and TypeMethodDescriptionViewFileSystemUtil.getStatus(FileSystem fileSystem, Path path) Get FsStatus for all ViewFsMountPoints matching path for the given ViewFileSystem.static booleanViewFileSystemUtil.isViewFileSystem(FileSystem fileSystem) Check if the FileSystem is a ViewFileSystem.static booleanViewFileSystemUtil.isViewFileSystemOverloadScheme(FileSystem fileSystem) Check if the FileSystem is a ViewFileSystemOverloadScheme. -
Uses of FileSystem in org.apache.hadoop.hdfs.server.namenode
Constructors in org.apache.hadoop.hdfs.server.namenode with parameters of type FileSystemModifierConstructorDescriptionTreePath(FileStatus stat, long parentId, org.apache.hadoop.hdfs.server.namenode.TreeWalk.TreeIterator i, FileSystem fs, AclStatus acls) -
Uses of FileSystem in org.apache.hadoop.io
Methods in org.apache.hadoop.io with parameters of type FileSystemModifier and TypeMethodDescriptionstatic org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, boolean createParent, SequenceFile.CompressionType compressionType, CompressionCodec codec, org.apache.hadoop.io.SequenceFile.Metadata metadata) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, org.apache.hadoop.io.SequenceFile.Metadata metadata) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, org.apache.hadoop.io.SequenceFile.Metadata metadata) Deprecated.static org.apache.hadoop.io.SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, Progressable progress) Deprecated.static voidBloomMapFile.delete(FileSystem fs, String name) static voidMapFile.delete(FileSystem fs, String name) Deletes the named map file.static longMapFile.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.static voidMapFile.rename(FileSystem fs, String oldName, String newName) Renames an existing map directory. -
Uses of FileSystem in org.apache.hadoop.io.wrappedio
Methods in org.apache.hadoop.io.wrappedio with parameters of type FileSystemModifier and TypeMethodDescriptionWrappedIO.bulkDelete_delete(FileSystem fs, Path base, Collection<Path> paths) Delete a list of files/objects.static intWrappedIO.bulkDelete_pageSize(FileSystem fs, Path path) Get the maximum number of objects/files to delete in a single request.static PathWrappedIO.fileSystem_getEnclosingRoot(FileSystem fs, Path path) Return path of the enclosing root for a given path.static FSDataInputStreamWrappedIO.fileSystem_openFile(FileSystem fs, Path path, String policy, FileStatus status, Long length, Map<String, String> options) OpenFile assistant, easy reflection-based access toopenFile(Path)and blocks awaiting the operation completion.static SerializableWrappedStatistics.iostatisticsSnapshot_load(FileSystem fs, Path path) Load IOStatisticsSnapshot from a Hadoop filesystem.static voidWrappedStatistics.iostatisticsSnapshot_save(Serializable snapshot, FileSystem fs, Path path, boolean overwrite) Save IOStatisticsSnapshot to a Hadoop filesystem as a JSON file. -
Uses of FileSystem in org.apache.hadoop.mapred
Methods in org.apache.hadoop.mapred that return FileSystemMethods in org.apache.hadoop.mapred with parameters of type FileSystemModifier and TypeMethodDescriptionprotected voidFileInputFormat.addInputPathRecursively(List<FileStatus> result, FileSystem fs, Path path, PathFilter inputFilter) Add files in the input path recursively into the results.voidFileOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) voidOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) Check for validity of the output-specification for the job.voidSequenceFileAsBinaryOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) static org.apache.hadoop.io.MapFile.Reader[]MapFileOutputFormat.getReaders(FileSystem ignored, Path dir, Configuration conf) Open the output generated by this format.abstract RecordWriter<K,V> FileOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) MapFileOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) OutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) Get theRecordWriterfor the given job.SequenceFileAsBinaryOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) SequenceFileOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) TextOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) static booleanJobClient.isJobDirValid(Path jobDirPath, FileSystem fs) Checks if the job directory is clean and has all the required components for (re) starting the jobprotected booleanFileInputFormat.isSplitable(FileSystem fs, Path filename) Is the given filename splittable?protected booleanFixedLengthInputFormat.isSplitable(FileSystem fs, Path file) protected booleanKeyValueTextInputFormat.isSplitable(FileSystem fs, Path file) protected booleanTextInputFormat.isSplitable(FileSystem fs, Path file) -
Uses of FileSystem in org.apache.hadoop.mapred.lib
Methods in org.apache.hadoop.mapred.lib with parameters of type FileSystemModifier and TypeMethodDescriptionvoidFilterOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) voidLazyOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) voidNullOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) protected abstract RecordWriter<K,V> MultipleOutputFormat.getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3) protected RecordWriter<K,V> MultipleSequenceFileOutputFormat.getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3) protected RecordWriter<K,V> MultipleTextOutputFormat.getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3) FilterOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) LazyOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) MultipleOutputFormat.getRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3) Create a composite record writer that can write key/value data to different output filesNullOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) protected booleanCombineFileInputFormat.isSplitable(FileSystem fs, Path file) -
Uses of FileSystem in org.apache.hadoop.mapred.lib.db
Methods in org.apache.hadoop.mapred.lib.db with parameters of type FileSystemModifier and TypeMethodDescriptionvoidDBOutputFormat.checkOutputSpecs(FileSystem filesystem, JobConf job) Check for validity of the output-specification for the job.DBOutputFormat.getRecordWriter(FileSystem filesystem, JobConf job, String name, Progressable progress) Get theRecordWriterfor the given job. -
Uses of FileSystem in org.apache.hadoop.mapreduce
Methods in org.apache.hadoop.mapreduce that return FileSystemModifier and TypeMethodDescriptionCluster.getFileSystem()Get the file system where job-specific files are storedMethods in org.apache.hadoop.mapreduce with parameters of type FileSystemModifier and TypeMethodDescriptionstatic voidJob.addArchiveToClassPath(Path archive, Configuration conf, FileSystem fs) Add an archive path to the current set of classpath entries.static voidJob.addFileToClassPath(Path file, Configuration conf, FileSystem fs) Add a file path to the current set of classpath entries.static voidJob.addFileToClassPath(Path file, Configuration conf, FileSystem fs, boolean addToCache) Add a file path to the current set of classpath entries. -
Uses of FileSystem in org.apache.hadoop.mapreduce.lib.input
Methods in org.apache.hadoop.mapreduce.lib.input with parameters of type FileSystemModifier and TypeMethodDescriptionprotected voidFileInputFormat.addInputPathRecursively(List<FileStatus> result, FileSystem fs, Path path, PathFilter inputFilter) Add files in the input path recursively into the results.protected BlockLocation[]CombineFileInputFormat.getFileBlockLocations(FileSystem fs, FileStatus stat) -
Uses of FileSystem in org.apache.hadoop.mapreduce.lib.output.committer.manifest.files
Methods in org.apache.hadoop.mapreduce.lib.output.committer.manifest.files with parameters of type FileSystemModifier and TypeMethodDescriptionstatic ManifestSuccessDataManifestSuccessData.load(FileSystem fs, Path path) Load an instance from a file, then validate it.voidManifestSuccessData.save(FileSystem fs, Path path, boolean overwrite) -
Uses of FileSystem in org.apache.hadoop.metrics2.sink
Fields in org.apache.hadoop.metrics2.sink declared as FileSystemModifier and TypeFieldDescriptionprotected static FileSystemRollingFileSystemSink.suppliedFilesystem -
Uses of FileSystem in org.apache.hadoop.yarn.logaggregation.filecontroller
Methods in org.apache.hadoop.yarn.logaggregation.filecontroller that return FileSystemModifier and TypeMethodDescriptionprotected FileSystemLogAggregationFileController.getFileSystem(Configuration conf) Methods in org.apache.hadoop.yarn.logaggregation.filecontroller with parameters of type FileSystemModifier and TypeMethodDescriptionprotected booleanLogAggregationFileController.checkExists(FileSystem fs, Path path, FsPermission fsPerm) protected voidLogAggregationFileController.createDir(FileSystem fs, Path path, FsPermission fsPerm)
get(URI, Configuration)instead.