public final class MultiBufferedRandomAccessFile
extends java.lang.Object
implements java.io.DataInput, java.io.DataOutput, java.io.Closeable
| Constructor and Description |
|---|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers)
Create a read-only random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
boolean flushUnloadedBuffers)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
boolean flushUnloadedBuffers,
boolean trackReloadedBlocks)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
byte[] prefillPattern)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
byte[] prefillPattern,
boolean trackReloadedBlocks)
Create a read-only or read-write random access file with the specified maximum number of buffers of the specified size.
|
| Modifier and Type | Method and Description |
|---|---|
void |
clearCache()
Clear the cache buffers.
|
void |
close()
Closes this file and releases any system resources
associated with the buffering.
|
void |
flush()
Flush all "dirty" (modified) buffers.
|
long |
getFilePointer()
Returns the current offset in this file.
|
int |
getNumConsecutiveHits()
Get number of consecutive times a read matched data already in the buffers or a write
overwrote data already in the buffers.
|
int |
getNumFlushes()
Get the number of times write-modified buffers had to be flushed to disk.
|
long |
getNumHits()
Get number of times a read matched data already in the buffers or a write
overwrote data already in the buffers.
|
long |
getNumMisses()
Get the number of times a read or write required loading a buffer from
disk.
|
int |
getNumReReads()
Get the number of times a block that had already been read into a buffer
was read again.
|
java.io.RandomAccessFile |
getRandomAccessFile()
Get the RandomAccessFile underlying this MultiBufferedRandomAccessFile.
|
int |
read()
Reads the next byte in the file at the current seek position.
|
boolean |
readBoolean()
See the general contract of the
readBoolean
method of DataInput. |
byte |
readByte()
See the general contract of the
readByte
method of DataInput. |
char |
readChar()
See the general contract of the
readChar
method of DataInput. |
double |
readDouble()
See the general contract of the
readDouble
method of DataInput. |
float |
readFloat()
See the general contract of the
readFloat
method of DataInput. |
void |
readFully(byte[] b)
See the general contract of the
readFully
method of DataInput. |
void |
readFully(byte[] b,
int off,
int len)
See the general contract of the
readFully
method of DataInput. |
int |
readInt()
See the general contract of the
readInt
method of DataInput. |
int |
readIntAt(long seekPos)
Bytes
for this operation are read from the contained
file.
|
java.lang.String |
readLine()
See the general contract of the
readLine
method of DataInput. |
long |
readLong()
See the general contract of the
readLong
method of DataInput. |
int |
readNextInt()
This is similar to
readInt(), but the caller must guarantee that no seek(long)
occurred between the last call to readInt() or readNextInt() and this one. |
short |
readShort()
See the general contract of the
readShort
method of DataInput. |
int |
readUnsignedByte()
See the general contract of the
readUnsignedByte
method of DataInput. |
int |
readUnsignedShort()
See the general contract of the
readUnsignedShort
method of DataInput. |
java.lang.String |
readUTF()
See the general contract of the
readUTF
method of DataInput. |
void |
resetOldPages()
If being used, clear the history of already-accessed pages.
|
void |
resetStatistics()
Reset the statistics counters that are reported by the toString() method.
|
void |
seek(long seekPos)
Sets the file-pointer offset, measured from the beginning of this
file, at which the next read occurs.
|
int |
skipBytes(int n)
See the general contract of the
skipBytes
method of DataInput. |
java.lang.String |
toString()
Returns a string representation of the object.
|
void |
write(byte[] b)
Writes to the output stream all the bytes in array
b. |
void |
write(byte[] b,
int off,
int len)
Writes
len bytes from array
b, in order, to
the output stream. |
void |
write(int b)
Writes to the output stream the eight
low-order bits of the argument
b. |
void |
write2Int(int v1,
int v2)
Writes 2
int values, each of which is
comprised of four bytes, to the output stream. |
void |
write2Int(long seekPos,
int v1,
int v2)
Sets the file-pointer offset, measured from the beginning of this
file, at which the next read occurs.
|
void |
writeBoolean(boolean v)
Writes a
boolean value to this output stream. |
void |
writeByte(int v)
Writes to the output stream the eight low-
order bits of the argument
v. |
void |
writeBytes(java.lang.String s)
Writes a string to the output stream.
|
void |
writeChar(int v)
Writes a
char value, which
is comprised of two bytes, to the
output stream. |
void |
writeChars(java.lang.String s)
Writes every character in the string
s,
to the output stream, in order,
two bytes per character. |
void |
writeDouble(double v)
Writes a
double value,
which is comprised of eight bytes, to the output stream. |
void |
writeFloat(float v)
Writes a
float value,
which is comprised of four bytes, to the output stream. |
void |
writeInt(int v)
Writes an
int value, which is
comprised of four bytes, to the output stream. |
void |
writeLong(long v)
Writes a
long value, which is
comprised of eight bytes, to the output stream. |
void |
writeShort(int v)
Writes two bytes to the output
stream to represent the value of the argument.
|
void |
writeUTF(java.lang.String s)
Writes two bytes of length information
to the output stream, followed
by the modified UTF-8 representation
of every character in the string
s. |
public MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers)
throws java.io.IOException
file - File pointing at the disk file to readbufSize - size of each buffer in bytes (must be a power of 2)maxBuffers - maximum number of buffers to usejava.io.IOException - if file cannot be opened for read-only accesspublic MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable)
throws java.io.IOException
file - File pointing at the disk file to readbufSize - size of each buffer in bytes (must be a power of 2)maxBuffers - maximum number of buffers to useisWriteable - boolean true if this file can be written tojava.io.IOException - if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
boolean flushUnloadedBuffers)
throws java.io.IOException
file - File pointing at the disk file to readbufSize - size of each buffer in bytes (must be a power of 2)maxBuffers - maximum number of buffers to useisWriteable - boolean true if this file can be written toflushUnloadedBuffers - specify whether capable systems should flush released buffers from
kernel filesystem cache to reduce cache overgrowthjava.io.IOException - if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
boolean flushUnloadedBuffers,
boolean trackReloadedBlocks)
throws java.io.IOException
file - File pointing at the disk file to readbufSize - size of each buffer in bytes (must be a power of 2)maxBuffers - maximum number of buffers to useisWriteable - boolean true if this file can be written toflushUnloadedBuffers - specify whether capable systems should flush released buffers from
kernel filesystem cache to reduce cache overgrowthtrackReloadedBlocks - boolean true if rereads of blocks should be tracked, false if notjava.io.IOException - if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
byte[] prefillPattern)
throws java.io.IOException
file - File pointing at the disk file to readbufSize - size of each buffer in bytes (must be a power of 2)maxBuffers - maximum number of buffers to useisWriteable - boolean true if this file can be written toprefillPattern - byte array to iteratively write to a new buffer as a fill patternjava.io.IOException - if file cannot be opened for the requested accesspublic MultiBufferedRandomAccessFile(java.io.File file,
int bufSize,
int maxBuffers,
boolean isWriteable,
byte[] prefillPattern,
boolean trackReloadedBlocks)
throws java.io.IOException
file - File pointing at the disk file to readbufSize - size of each buffer in bytes (must be a power of 2)maxBuffers - maximum number of buffers to useisWriteable - boolean true if this file can be written toprefillPattern - byte array to iteratively write to a new buffer as a fill patterntrackReloadedBlocks - boolean true if rereads of blocks should be tracked, false if notjava.io.IOException - if file cannot be opened for the requested accesspublic int read()
throws java.io.IOException
java.io.EOFException - if attempt to read past the end of filejava.io.IOException - if this input stream has been closed by
invoking its close() method,
or an I/O error occurs.seek(long)public boolean readBoolean()
throws java.io.IOException
readBoolean
method of DataInput.
Bytes for this operation are read from the contained file.
readBoolean in interface java.io.DataInputboolean value read.java.io.EOFException - if this input stream has reached the end.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public byte readByte()
throws java.io.IOException
readByte
method of DataInput.
Bytes for this operation are read from the contained file.
readByte in interface java.io.DataInputbyte.java.io.EOFException - if this input stream has reached the end.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public char readChar()
throws java.io.IOException
readChar
method of DataInput.
Bytes for this operation are read from the contained input stream.
readChar in interface java.io.DataInputchar.java.io.EOFException - if this input stream reaches the end before
reading two bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public double readDouble()
throws java.io.IOException
readDouble
method of DataInput.
Bytes for this operation are read from the contained file.
readDouble in interface java.io.DataInputdouble.java.io.EOFException - if this input stream reaches the end before
reading eight bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.DataInputStream.readLong(),
Double.longBitsToDouble(long)public float readFloat()
throws java.io.IOException
readFloat
method of DataInput.
Bytes for this operation are read from the contained file.
readFloat in interface java.io.DataInputfloat.java.io.EOFException - if this input stream reaches the end before
reading four bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.DataInputStream.readInt(),
Float.intBitsToFloat(int)public void readFully(byte[] b)
throws java.io.IOException
readFully
method of DataInput.
Bytes for this operation are read from the contained file.
readFully in interface java.io.DataInputb - the buffer into which the data is read.java.io.EOFException - if this input stream reaches the end before
reading all the bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public void readFully(byte[] b,
int off,
int len)
throws java.io.IOException
readFully
method of DataInput.
Bytes for this operation are read from the contained file.
readFully in interface java.io.DataInputb - the buffer into which the data is read.off - the start offset of the data.len - the number of bytes to read.java.io.EOFException - if this input stream reaches the end before
reading all the bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public int readInt()
throws java.io.IOException
readInt
method of DataInput.
Bytes for this operation are read from the contained file.
readInt in interface java.io.DataInputint.java.io.EOFException - if this input stream reaches the end before
reading four bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public java.lang.String readLine()
throws java.io.IOException
readLine
method of DataInput.
Bytes for this operation are read from the contained file. Note that this method only supports extended 8-bit ASCII (ISO-8859-1); it does not support UTF-8 or other locale-specific character sets.
readLine in interface java.io.DataInputjava.io.IOException - if an I/O error occurs.public long readLong()
throws java.io.IOException
readLong
method of DataInput.
Bytes for this operation are read from the contained file.
readLong in interface java.io.DataInputlong.java.io.EOFException - if this input stream reaches the end before
reading eight bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public short readShort()
throws java.io.IOException
readShort
method of DataInput.
Bytes for this operation are read from the contained file.
readShort in interface java.io.DataInputjava.io.EOFException - if this input stream reaches the end before
reading two bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public int readUnsignedByte()
throws java.io.IOException
readUnsignedByte
method of DataInput.
Bytes for this operation are read from the contained file.
readUnsignedByte in interface java.io.DataInputjava.io.EOFException - if this input stream has reached the end.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public int readUnsignedShort()
throws java.io.IOException
readUnsignedShort
method of DataInput.
Bytes for this operation are read from the contained file.
readUnsignedShort in interface java.io.DataInputjava.io.EOFException - if this input stream reaches the end before
reading two bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public java.lang.String readUTF()
throws java.io.IOException
readUTF
method of DataInput.
Bytes for this operation are read from the contained file.
readUTF in interface java.io.DataInputjava.io.EOFException - if this input stream reaches the end before
reading all the bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.java.io.UTFDataFormatException - if the bytes do not represent a valid
modified UTF-8 encoding of a string.public int skipBytes(int n)
skipBytes
method of DataInput.
No actual bytes are read; the current file seek position pointer is merely updated in preparation for later I/O.
skipBytes in interface java.io.DataInputn - the number of bytes to be skipped.public void seek(long seekPos)
seekPos - the offset position, measured in bytes from the
beginning of the file, at which to set the file
pointer.public int readIntAt(long seekPos)
throws java.io.IOException
seekPos - the offset position, measured in bytes from the
beginning of the file, at which to set the file
pointer.int.java.io.EOFException - if this input stream reaches the end before
reading four bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public long getFilePointer()
public void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseablejava.io.IOException - if an I/O error occurs.public java.lang.String toString()
toString in class java.lang.Objectpublic void resetStatistics()
toString()public void resetOldPages()
public long getNumHits()
resetStatistics()public int getNumConsecutiveHits()
resetStatistics()public long getNumMisses()
resetStatistics()public int getNumFlushes()
resetStatistics()public int getNumReReads()
public int readNextInt()
throws java.io.IOException
readInt(), but the caller must guarantee that no seek(long)
occurred between the last call to readInt() or readNextInt() and this one.int.java.io.EOFException - if this input stream reaches the end before
reading four bytes.java.io.IOException - the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.readInt()public void clearCache()
public void write(byte[] b)
throws java.io.IOException
b.
If b is null,
a NullPointerException is thrown.
If b.length is zero, then
no bytes are written. Otherwise, the byte
b[0] is written first, then
b[1], and so on; the last byte
written is b[b.length-1].write in interface java.io.DataOutputb - the data.java.io.IOException - if an I/O error occurs.public void write(int b)
throws java.io.IOException
b.
The 24 high-order bits of b
are ignored.write in interface java.io.DataOutputb - the byte to be written.java.io.IOException - if an I/O error occurs.public void write(byte[] b,
int off,
int len)
throws java.io.IOException
len bytes from array
b, in order, to
the output stream. If b
is null, a NullPointerException
is thrown. If off is negative,
or len is negative, or off+len
is greater than the length of the array
b, then an IndexOutOfBoundsException
is thrown. If len is zero,
then no bytes are written. Otherwise, the
byte b[off] is written first,
then b[off+1], and so on; the
last byte written is b[off+len-1].write in interface java.io.DataOutputb - the data.off - the start offset in the data.len - the number of bytes to write.java.io.IOException - if an I/O error occurs.public void writeBoolean(boolean v)
throws java.io.IOException
boolean value to this output stream.
If the argument v
is true, the value (byte)1
is written; if v is false,
the value (byte)0 is written.
The byte written by this method may
be read by the readBoolean
method of interface DataInput,
which will then return a boolean
equal to v.writeBoolean in interface java.io.DataOutputv - the boolean to be written.java.io.IOException - if an I/O error occurs.public void writeByte(int v)
throws java.io.IOException
v.
The 24 high-order bits of v
are ignored. (This means that writeByte
does exactly the same thing as write
for an integer argument.) The byte written
by this method may be read by the readByte
method of interface DataInput,
which will then return a byte
equal to (byte)v.writeByte in interface java.io.DataOutputv - the byte value to be written.java.io.IOException - if an I/O error occurs.public void writeShort(int v)
throws java.io.IOException
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be
read by the readShort method
of interface DataInput , which
will then return a short equal
to (short)v.writeShort in interface java.io.DataOutputv - the short value to be written.java.io.IOException - if an I/O error occurs.public void writeChar(int v)
throws java.io.IOException
char value, which
is comprised of two bytes, to the
output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be
read by the readChar method
of interface DataInput , which
will then return a char equal
to (char)v.writeChar in interface java.io.DataOutputv - the char value to be written.java.io.IOException - if an I/O error occurs.public void writeInt(int v)
throws java.io.IOException
int value, which is
comprised of four bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be read
by the readInt method of interface
DataInput , which will then
return an int equal to v.writeInt in interface java.io.DataOutputv - the int value to be written.java.io.IOException - if an I/O error occurs.public void write2Int(int v1,
int v2)
throws java.io.IOException
int values, each of which is
comprised of four bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be read
by the readInt method of interface
DataInput , which will then
return an int equal to v.v1 - the first int value to be written.v2 - the first int value to be written.java.io.IOException - if an I/O error occurs.public void write2Int(long seekPos,
int v1,
int v2)
throws java.io.IOException
int values, each of which is
comprised of four bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be read
by the readInt method of interface
DataInput , which will then
return an int equal to v1 or v2.seekPos - the offset position, measured in bytes from the
beginning of the file, at which to set the file
pointer.v1 - the first int value to be written.v2 - the first int value to be written.java.io.IOException - if an I/O error occurs.public void writeLong(long v)
throws java.io.IOException
long value, which is
comprised of eight bytes, to the output stream.
The byte values to be written, in the order
shown, are:
(byte)(0xff & (v >> 56))
(byte)(0xff & (v >> 48))
(byte)(0xff & (v >> 40))
(byte)(0xff & (v >> 32))
(byte)(0xff & (v >> 24))
(byte)(0xff & (v >> 16))
(byte)(0xff & (v >> 8))
(byte)(0xff & v)
The bytes written by this method may be
read by the readLong method
of interface DataInput , which
will then return a long equal
to v.writeLong in interface java.io.DataOutputv - the long value to be written.java.io.IOException - if an I/O error occurs.public void writeFloat(float v)
throws java.io.IOException
float value,
which is comprised of four bytes, to the output stream.
It does this as if it first converts this
float value to an int
in exactly the manner of the Float.floatToIntBits
method and then writes the int
value in exactly the manner of the writeInt
method. The bytes written by this method
may be read by the readFloat
method of interface DataInput,
which will then return a float
equal to v.writeFloat in interface java.io.DataOutputv - the float value to be written.java.io.IOException - if an I/O error occurs.public void writeDouble(double v)
throws java.io.IOException
double value,
which is comprised of eight bytes, to the output stream.
It does this as if it first converts this
double value to a long
in exactly the manner of the Double.doubleToLongBits
method and then writes the long
value in exactly the manner of the writeLong
method. The bytes written by this method
may be read by the readDouble
method of interface DataInput,
which will then return a double
equal to v.writeDouble in interface java.io.DataOutputv - the double value to be written.java.io.IOException - if an I/O error occurs.public void writeBytes(java.lang.String s)
throws java.io.IOException
s, taken in order, one byte
is written to the output stream. If
s is null, a NullPointerException
is thrown. If s.length
is zero, then no bytes are written. Otherwise,
the character s[0] is written
first, then s[1], and so on;
the last character written is s[s.length-1].
For each character, one byte is written,
the low-order byte, in exactly the manner
of the writeByte method . The
high-order eight bits of each character
in the string are ignored.
writeBytes in interface java.io.DataOutputs - the string of bytes to be written.java.io.IOException - if an I/O error occurs.public void writeChars(java.lang.String s)
throws java.io.IOException
s,
to the output stream, in order,
two bytes per character. If s
is null, a NullPointerException
is thrown. If s.length
is zero, then no characters are written.
Otherwise, the character s[0]
is written first, then s[1],
and so on; the last character written is
s[s.length-1]. For each character,
two bytes are actually written, high-order
byte first, in exactly the manner of the
writeChar method.writeChars in interface java.io.DataOutputs - the string value to be written.java.io.IOException - if an I/O error occurs.public void writeUTF(java.lang.String s)
throws java.io.IOException
s.
If s is null,
a NullPointerException is thrown.
Each character in the string s
is converted to a group of one, two, or
three bytes, depending on the value of the
character.
If a character c
is in the range \u0001 through
\u007f, it is represented
by one byte:
(byte)cIf a character
c is \u0000
or is in the range \u0080
through \u07ff, then it is
represented by two bytes, to be written
in the order shown:
(byte)(0xc0 | (0x1f & (c >> 6)))
(byte)(0x80 | (0x3f & c))
If a character
c is in the range \u0800
through uffff, then it is
represented by three bytes, to be written
in the order shown:
(byte)(0xe0 | (0x0f & (c >> 12)))
(byte)(0x80 | (0x3f & (c >> 6)))
(byte)(0x80 | (0x3f & c))
First,
the total number of bytes needed to represent
all the characters of s is
calculated. If this number is larger than
65535, then a UTFDataFormatException
is thrown. Otherwise, this length is written
to the output stream in exactly the manner
of the writeShort method;
after this, the one-, two-, or three-byte
representation of each character in the
string s is written.
The
bytes written by this method may be read
by the readUTF method of interface
DataInput , which will then
return a String equal to s.
writeUTF in interface java.io.DataOutputs - the string value to be written.java.io.IOException - if an I/O error occurs.public void flush()
throws java.io.IOException
java.io.IOException - if dirty buffers can't be written to diskgetNumFlushes()public java.io.RandomAccessFile getRandomAccessFile()
OSAdapter.releaseOldPages(RandomAccessFile, long, long)