@InterfaceAudience.Private @InterfaceStability.Unstable public class BufferedFSInputStream extends BufferedInputStream implements Seekable, PositionedReadable, HasFileDescriptor
in
Constructor and Description |
---|
BufferedFSInputStream(FSInputStream in,
int size)
Creates a
BufferedFSInputStream
with the specified buffer size,
and saves its argument, the input stream
in , for later use. |
Modifier and Type | Method and Description |
---|---|
FileDescriptor |
getFileDescriptor() |
long |
getPos()
Return the current offset from the start of the file
|
int |
read(long position,
byte[] buffer,
int offset,
int length)
Read upto the specified number of bytes, from a given
position within a file, and return the number of bytes read.
|
void |
readFully(long position,
byte[] buffer)
Read number of bytes equal to the length of the buffer, from a given
position within a file.
|
void |
readFully(long position,
byte[] buffer,
int offset,
int length)
Read the specified number of bytes, from a given
position within a file.
|
void |
seek(long pos)
Seek to the given offset from the start of the file.
|
boolean |
seekToNewSource(long targetPos)
Seeks a different copy of the data.
|
long |
skip(long n) |
available, close, mark, markSupported, read, read, reset
read
public BufferedFSInputStream(FSInputStream in, int size)
BufferedFSInputStream
with the specified buffer size,
and saves its argument, the input stream
in
, for later use. An internal
buffer array of length size
is created and stored in buf
.in
- the underlying input stream.size
- the buffer size.IllegalArgumentException
- if size <= 0.public long getPos() throws IOException
Seekable
getPos
in interface Seekable
IOException
public long skip(long n) throws IOException
skip
in class BufferedInputStream
IOException
public void seek(long pos) throws IOException
Seekable
seek
in interface Seekable
IOException
public boolean seekToNewSource(long targetPos) throws IOException
Seekable
seekToNewSource
in interface Seekable
IOException
public int read(long position, byte[] buffer, int offset, int length) throws IOException
PositionedReadable
read
in interface PositionedReadable
IOException
public void readFully(long position, byte[] buffer, int offset, int length) throws IOException
PositionedReadable
readFully
in interface PositionedReadable
IOException
public void readFully(long position, byte[] buffer) throws IOException
PositionedReadable
readFully
in interface PositionedReadable
IOException
public FileDescriptor getFileDescriptor() throws IOException
getFileDescriptor
in interface HasFileDescriptor
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.