Package org.apache.pdfbox.io
Class RandomAccessBufferedFileInputStream
java.lang.Object
java.io.InputStream
org.apache.pdfbox.io.RandomAccessBufferedFileInputStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
,RandomAccessRead
Provides
InputStream
access to portions of a file combined with
buffered reading of content. Start of next bytes to read can be set via seek
method.
File is accessed via RandomAccessFile
and is read in byte chunks
which are cached.-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate byte[]
private long
private final long
private long
private boolean
private byte[]
private int
private int
Create a LRU page cache.private long
private int
private int
private final RandomAccessFile
private File
private static final String
The prefix for the temp file being used. -
Constructor Summary
ConstructorsConstructorDescriptionCreate a random access input stream instance for the given file.Create a random access input stream for the given input stream by copying the data to a temporary file.RandomAccessBufferedFileInputStream
(String filename) Create a random access input stream instance for the file with the given name. -
Method Summary
Modifier and TypeMethodDescriptionint
Returns an estimate of the number of bytes that can be read.void
close()
private File
createTmpFile
(InputStream input) private void
Remove the temporary file.long
Returns offset in file at which next byte would be read.boolean
isClosed()
Returns true if this stream has been closed.boolean
isEOF()
A simple test to see if we are at the end of the data.long
length()
The total number of bytes that are available.int
peek()
This will peek at the next byte.int
read()
Read a single byte of data.int
read
(byte[] b) Read a buffer of data.int
read
(byte[] b, int off, int len) Read a buffer of data.byte[]
readFully
(int length) Reads a given number of bytes.private byte[]
readPage()
Reads a page with data from current file position.void
rewind
(int bytes) Seek backwards the given number of bytes.void
seek
(long newOffset) Seeks to new position.long
skip
(long n) Methods inherited from class java.io.InputStream
mark, markSupported, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skipNBytes, transferTo
-
Field Details
-
TMP_FILE_PREFIX
The prefix for the temp file being used.- See Also:
-
pageSizeShift
private int pageSizeShift -
pageSize
private int pageSize -
pageOffsetMask
private long pageOffsetMask -
maxCachedPages
private int maxCachedPages -
tempFile
-
lastRemovedCachePage
private byte[] lastRemovedCachePage -
pageCache
Create a LRU page cache. -
curPageOffset
private long curPageOffset -
curPage
private byte[] curPage -
offsetWithinPage
private int offsetWithinPage -
raFile
-
fileLength
private final long fileLength -
fileOffset
private long fileOffset -
isClosed
private boolean isClosed
-
-
Constructor Details
-
RandomAccessBufferedFileInputStream
Create a random access input stream instance for the file with the given name.- Parameters:
filename
- the filename of the file to be read.- Throws:
IOException
- if something went wrong while accessing the given file.
-
RandomAccessBufferedFileInputStream
Create a random access input stream instance for the given file.- Parameters:
file
- the file to be read.- Throws:
IOException
- if something went wrong while accessing the given file.
-
RandomAccessBufferedFileInputStream
Create a random access input stream for the given input stream by copying the data to a temporary file.- Parameters:
input
- the input stream to be read. It will be closed by this method.- Throws:
IOException
- if something went wrong while creating the temporary file.
-
-
Method Details
-
createTmpFile
- Throws:
IOException
-
deleteTempFile
private void deleteTempFile()Remove the temporary file. A temporary file is created if this class is instantiated with an InputStream -
getPosition
public long getPosition()Returns offset in file at which next byte would be read.- Specified by:
getPosition
in interfaceRandomAccessRead
- Returns:
- offset of next byte which will be returned with next
RandomAccessRead.read()
(if no more bytes are left it returns a value >= length of source)
-
seek
Seeks to new position. If new position is outside of current page the new page is either taken from cache or read from file and added to cache.- Specified by:
seek
in interfaceRandomAccessRead
- Parameters:
newOffset
- the position to seek to.- Throws:
IOException
- if something went wrong.
-
readPage
Reads a page with data from current file position. If we have a previously removed page from cache the buffer of this page is reused. Otherwise a new byte buffer is created.- Throws:
IOException
-
read
Description copied from interface:RandomAccessRead
Read a single byte of data.- Specified by:
read
in interfaceRandomAccessRead
- Specified by:
read
in classInputStream
- Returns:
- The byte of data that is being read.
- Throws:
IOException
- If there is an error while reading the data.
-
read
Description copied from interface:RandomAccessRead
Read a buffer of data.- Specified by:
read
in interfaceRandomAccessRead
- Overrides:
read
in classInputStream
- Parameters:
b
- The buffer to write the data to.- Returns:
- The number of bytes that were actually read.
- Throws:
IOException
- If there was an error while reading the data.
-
read
Description copied from interface:RandomAccessRead
Read a buffer of data.- Specified by:
read
in interfaceRandomAccessRead
- Overrides:
read
in classInputStream
- Parameters:
b
- The buffer to write the data to.off
- Offset into the buffer to start writing.len
- The amount of data to attempt to read.- Returns:
- The number of bytes that were actually read.
- Throws:
IOException
- If there was an error while reading the data.
-
available
Description copied from interface:RandomAccessRead
Returns an estimate of the number of bytes that can be read.- Specified by:
available
in interfaceRandomAccessRead
- Overrides:
available
in classInputStream
- Returns:
- the number of bytes that can be read
- Throws:
IOException
- if this random access has been closed
-
skip
- Overrides:
skip
in classInputStream
- Throws:
IOException
-
length
Description copied from interface:RandomAccessRead
The total number of bytes that are available.- Specified by:
length
in interfaceRandomAccessRead
- Returns:
- The number of bytes available.
- Throws:
IOException
- If there is an IO error while determining the length of the data stream.
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classInputStream
- Throws:
IOException
-
isClosed
public boolean isClosed()Description copied from interface:RandomAccessRead
Returns true if this stream has been closed.- Specified by:
isClosed
in interfaceRandomAccessRead
-
peek
Description copied from interface:RandomAccessRead
This will peek at the next byte.- Specified by:
peek
in interfaceRandomAccessRead
- Returns:
- The next byte on the stream, leaving it as available to read.
- Throws:
IOException
- If there is an error reading the next byte.
-
rewind
Description copied from interface:RandomAccessRead
Seek backwards the given number of bytes.- Specified by:
rewind
in interfaceRandomAccessRead
- Parameters:
bytes
- the number of bytes to be seeked backwards- Throws:
IOException
- If there is an error while seeking
-
readFully
Description copied from interface:RandomAccessRead
Reads a given number of bytes.- Specified by:
readFully
in interfaceRandomAccessRead
- Parameters:
length
- the number of bytes to be read- Returns:
- a byte array containing the bytes just read
- Throws:
IOException
- if an I/O error occurs while reading data
-
isEOF
Description copied from interface:RandomAccessRead
A simple test to see if we are at the end of the data.- Specified by:
isEOF
in interfaceRandomAccessRead
- Returns:
- true if we are at the end of the data.
- Throws:
IOException
- If there is an error reading the next byte.
-