Uses of Interface
org.apache.hadoop.fs.FileRange
Packages that use FileRange
Package
Description
An abstract file system API.
This package contains implementation classes for use inside
filesystems.
-
Uses of FileRange in org.apache.hadoop.fs
Methods in org.apache.hadoop.fs with type parameters of type FileRangeModifier and TypeMethodDescriptionstatic <T extends FileRange>
TVectoredReadUtils.validateRangeRequest(T range) Validate a single range.Methods in org.apache.hadoop.fs that return FileRangeModifier and TypeMethodDescriptionstatic FileRangeFileRange.createFileRange(long offset, int length) Factory method to create a FileRange object.static FileRangeFileRange.createFileRange(long offset, int length, Object reference) Factory method to create a FileRange object.static FileRange[]VectoredReadUtils.sortRanges(List<? extends FileRange> input) Sort the input ranges by offset; no validation is done.Methods in org.apache.hadoop.fs that return types with arguments of type FileRangeModifier and TypeMethodDescriptionVectoredReadUtils.sortRangeList(List<? extends FileRange> input) Sort the input ranges by offset; no validation is done.VectoredReadUtils.validateAndSortRanges(List<? extends FileRange> input, Optional<Long> fileLength) Validate a list of ranges (including overlapping checks) and return the sorted list.Methods in org.apache.hadoop.fs with parameters of type FileRangeModifier and TypeMethodDescriptionstatic voidVectoredReadUtils.readInDirectBuffer(FileRange range, ByteBuffer buffer, Function4RaisingIOE<Long, byte[], Integer, Integer, Void> operation) Read bytes from stream into a byte buffer using an intermediate byte array.static CompletableFuture<ByteBuffer>VectoredReadUtils.readRangeFrom(PositionedReadable stream, FileRange range, IntFunction<ByteBuffer> allocate) Synchronously reads a range from the stream dealing with the combinations of ByteBuffers buffers and PositionedReadable streams.static CompletableFuture<ByteBuffer>VectoredReadUtils.readRangeFrom(PositionedReadable stream, FileRange range, IntFunction<ByteBuffer> allocate, Consumer<ByteBuffer> release) Synchronously reads a range from the stream dealing with the combinations of ByteBuffers buffers and PositionedReadable streams.static ByteBufferVectoredReadUtils.sliceTo(ByteBuffer readData, long readOffset, FileRange request) Slice the data that was read to the user's request.Method parameters in org.apache.hadoop.fs with type arguments of type FileRangeModifier and TypeMethodDescriptionstatic booleanVectoredReadUtils.isOrderedDisjoint(List<? extends FileRange> input, int chunkSize, int minimumSeek) Is the given input list.static List<CombinedFileRange>VectoredReadUtils.mergeSortedRanges(List<? extends FileRange> sortedRanges, int chunkSize, int minimumSeek, int maxSize) Merge sorted ranges to optimize the access from the underlying file system.voidBufferedFSInputStream.readVectored(List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate) voidBufferedFSInputStream.readVectored(List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate, Consumer<ByteBuffer> release) voidFSDataInputStream.readVectored(List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate) voidFSDataInputStream.readVectored(List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate, Consumer<ByteBuffer> release) default voidPositionedReadable.readVectored(List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate) Read fully a list of file ranges asynchronously from this file.default voidPositionedReadable.readVectored(List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate, Consumer<ByteBuffer> release) Extension ofPositionedReadable.readVectored(List, IntFunction)where arelease(buffer)operation may be invoked if problems surface during reads.static voidVectoredReadUtils.readVectored(PositionedReadable stream, List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate) This is the default implementation which iterates through the ranges to read each synchronously, but the intent is that subclasses can make more efficient readers.static voidVectoredReadUtils.readVectored(PositionedReadable stream, List<? extends FileRange> ranges, IntFunction<ByteBuffer> allocate, Consumer<ByteBuffer> release) Variant ofVectoredReadUtils.readVectored(PositionedReadable, List, IntFunction)where a release() function is invoked if problems surface during reads.VectoredReadUtils.sortRangeList(List<? extends FileRange> input) Sort the input ranges by offset; no validation is done.static FileRange[]VectoredReadUtils.sortRanges(List<? extends FileRange> input) Sort the input ranges by offset; no validation is done.VectoredReadUtils.validateAndSortRanges(List<? extends FileRange> input, Optional<Long> fileLength) Validate a list of ranges (including overlapping checks) and return the sorted list.static voidVectoredReadUtils.validateVectoredReadRanges(List<? extends FileRange> ranges) Validate a list of vectored read ranges. -
Uses of FileRange in org.apache.hadoop.fs.impl
Classes in org.apache.hadoop.fs.impl that implement FileRangeModifier and TypeClassDescriptionclassA file range that represents a set of underlying file ranges.classA range of bytes from a file with an optional buffer to read those bytes for zero copy.Methods in org.apache.hadoop.fs.impl that return types with arguments of type FileRangeModifier and TypeMethodDescriptionCombinedFileRange.getUnderlying()Get the list of ranges that were merged together to form this one.Methods in org.apache.hadoop.fs.impl with parameters of type FileRangeModifier and TypeMethodDescriptionbooleanMerge this input range into the current one, if it is compatible.Constructors in org.apache.hadoop.fs.impl with parameters of type FileRange