Uses of Interface
org.apache.hadoop.util.Progressable
Packages that use Progressable
Package
Description
An abstract file system API.
SFTP FileSystem package.
ViewFileSystem and ViewFileSystemOverloadScheme classes.
Generic i/o code for use when reading and writing data to the network,
to databases, and to files.
Common utilities.
-
Uses of Progressable in org.apache.hadoop.fs
Methods in org.apache.hadoop.fs that return ProgressableModifier and TypeMethodDescriptionprotected ProgressableFSDataOutputStreamBuilder.getProgress()Options.CreateOpts.Progress.getValue()Methods in org.apache.hadoop.fs with parameters of type ProgressableModifier and TypeMethodDescriptionChecksumFileSystem.append(Path f, int bufferSize, Progressable progress) abstract FSDataOutputStreamFileSystem.append(Path f, int bufferSize, Progressable progress) Append to an existing file (optional operation).FileSystem.append(Path f, int bufferSize, Progressable progress, boolean appendToNewBlock) Append to an existing file (optional operation).FilterFileSystem.append(Path f, int bufferSize, Progressable progress) HarFileSystem.append(Path f, int bufferSize, Progressable progress) RawLocalFileSystem.append(Path f, int bufferSize, Progressable progress) ChecksumFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) ChecksumFileSystem.create(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt) FileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) Create an FSDataOutputStream at the indicated Path with write-progress reporting.FileSystem.create(Path f, boolean overwrite, int bufferSize, Progressable progress) Create anFSDataOutputStreamat the indicated Path with write-progress reporting.FileSystem.create(Path f, short replication, Progressable progress) Create an FSDataOutputStream at the indicated Path with write-progress reporting.abstract FSDataOutputStreamFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) Create an FSDataOutputStream at the indicated Path with write-progress reporting.FileSystem.create(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) Create an FSDataOutputStream at the indicated Path with write-progress reporting.FileSystem.create(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt) Create an FSDataOutputStream at the indicated Path with a custom checksum option.FileSystem.create(Path f, Progressable progress) Create an FSDataOutputStream at the indicated Path with write-progress reporting.FilterFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) FilterFileSystem.create(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt) HarFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) RawLocalFileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) RawLocalFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) abstract FSDataOutputStreamAbstractFileSystem.createInternal(Path f, EnumSet<CreateFlag> flag, FsPermission absolutePermission, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt, boolean createParent) The specification of this method matches that ofAbstractFileSystem.create(Path, EnumSet, Options.CreateOpts...)except that the opts have been declared explicitly.ChecksumFs.createInternal(Path f, EnumSet<CreateFlag> createFlag, FsPermission absolutePermission, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt, boolean createParent) DelegateToFileSystem.createInternal(Path f, EnumSet<CreateFlag> flag, FsPermission absolutePermission, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt, boolean createParent) FilterFs.createInternal(Path f, EnumSet<CreateFlag> flag, FsPermission absolutePermission, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt, boolean createParent) ChecksumFileSystem.createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) ChecksumFileSystem.createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) FileSystem.createNonRecursive(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) Opens an FSDataOutputStream at the indicated Path with write-progress reporting.FileSystem.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.FileSystem.createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) Opens an FSDataOutputStream at the indicated Path with write-progress reporting.FilterFileSystem.createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) HarFileSystem.createNonRecursive(Path f, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) RawLocalFileSystem.createNonRecursive(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) RawLocalFileSystem.createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) protected FSDataOutputStreamFileSystem.primitiveCreate(Path f, FsPermission absolutePermission, EnumSet<CreateFlag> flag, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt) Deprecated.protected FSDataOutputStreamFilterFileSystem.primitiveCreate(Path f, FsPermission absolutePermission, EnumSet<CreateFlag> flag, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt) FSDataOutputStreamBuilder.progress(Progressable prog) Set the facility of reporting progress.static Options.CreateOpts.ProgressOptions.CreateOpts.progress(Progressable prog) Constructors in org.apache.hadoop.fs with parameters of type Progressable -
Uses of Progressable in org.apache.hadoop.fs.ftp
Methods in org.apache.hadoop.fs.ftp with parameters of type ProgressableModifier and TypeMethodDescriptionFTPFileSystem.append(Path f, int bufferSize, Progressable progress) This optional operation is not yet supported.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. -
Uses of Progressable in org.apache.hadoop.fs.sftp
Methods in org.apache.hadoop.fs.sftp with parameters of type ProgressableModifier and TypeMethodDescriptionSFTPFileSystem.append(Path f, int bufferSize, Progressable progress) SFTPFileSystem.create(Path f, 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. -
Uses of Progressable in org.apache.hadoop.fs.viewfs
Methods in org.apache.hadoop.fs.viewfs with parameters of type ProgressableModifier and TypeMethodDescriptionViewFileSystem.append(Path f, int bufferSize, Progressable progress) ViewFileSystem.create(Path f, FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) ViewFs.createInternal(Path f, EnumSet<CreateFlag> flag, FsPermission absolutePermission, int bufferSize, short replication, long blockSize, Progressable progress, Options.ChecksumOpt checksumOpt, boolean createParent) ViewFileSystem.createNonRecursive(Path f, FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) -
Uses of Progressable in org.apache.hadoop.io
Methods in org.apache.hadoop.io with parameters of type ProgressableModifier and TypeMethodDescriptionSequenceFile.Sorter.cloneFileAttributes(Path inputFile, Path outputFile, Progressable prog) Clones the attributes (like compression of the input file and creates a corresponding Writerstatic 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, SequenceFile.Metadata metadata) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, SequenceFile.Metadata metadata) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, Progressable progress) Deprecated.static SequenceFile.Writer.OptionMapFile.Writer.progressable(Progressable value) static SequenceFile.Writer.OptionSequenceFile.Writer.progressable(Progressable value) voidSequenceFile.Sorter.setProgressable(Progressable progressable) Set the progressable object in order to report progress.Constructors in org.apache.hadoop.io with parameters of type ProgressableModifierConstructorDescriptionWriter(Configuration conf, FileSystem fs, String file, Class<? extends Writable> valClass, SequenceFile.CompressionType compress, Progressable progress) Create the named file for values of the named class.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class<? extends Writable> valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...)} instead.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, Progressable progress, SequenceFile.Metadata metadata) Deprecated.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, Progressable progress, SequenceFile.Metadata metadata) Deprecated. -
Uses of Progressable in org.apache.hadoop.util
Methods in org.apache.hadoop.util that return ProgressableMethods in org.apache.hadoop.util with parameters of type ProgressableModifier and TypeMethodDescriptionvoidHeapSort.sort(IndexedSortable s, int p, int r, Progressable rep) voidIndexedSorter.sort(IndexedSortable s, int l, int r, Progressable rep) Same asIndexedSorter.sort(IndexedSortable,int,int), but indicate progress periodically.voidQuickSort.sort(IndexedSortable s, int p, int r, Progressable rep) Constructors in org.apache.hadoop.util with parameters of type Progressable
SequenceFile.createWriter(Configuration, Writer.Option...)instead.