org.apache.flink.runtime.state.filesystem

Class FsSegmentDataInputStream

java.lang.Object

java.io.InputStream

org.apache.flink.core.fs.FSDataInputStream

org.apache.flink.core.fs.FSDataInputStreamWrapper

org.apache.flink.runtime.state.filesystem.FsSegmentDataInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, WrappingProxyCloseable<FSDataInputStream>, WrappingProxy<FSDataInputStream>

public class FsSegmentDataInputStream
extends FSDataInputStreamWrapper
implements WrappingProxyCloseable<FSDataInputStream>

This class is a WrappingProxy for FSDataInputStream that is used to read from a file segment. It is opened with a starting position of the file. It treats the argument of seek(long) as an offset relative to the starting position, rather than an absolute value.

Field Summary

Fields inherited from class org.apache.flink.core.fs.FSDataInputStreamWrapper

inputStream

Constructor Summary

Constructors

Constructor and Description
FsSegmentDataInputStream(FSDataInputStream inputStream, long startingPosition, long segmentSize)

Method Summary

Modifier and Type	Method and Description
long	getPos() Gets the current position in the input stream.
void	mark(int readlimit)
boolean	markSupported()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
void	reset()
void	seek(long desired) Seek to the given offset from the start of the file.
long	skip(long n)

Methods inherited from class org.apache.flink.core.fs.FSDataInputStreamWrapper

available, close, getWrappedDelegate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface org.apache.flink.util.WrappingProxy

getWrappedDelegate

Constructor Detail

FsSegmentDataInputStream

public FsSegmentDataInputStream(FSDataInputStream inputStream,
                                long startingPosition,
                                long segmentSize)
                         throws IOException

Throws:

IOException

Method Detail

read

public int read()
         throws IOException

Overrides:

read in class FSDataInputStreamWrapper

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class FSDataInputStreamWrapper

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class FSDataInputStreamWrapper

Throws:

IOException

seek

public void seek(long desired)
          throws IOException

Description copied from class: FSDataInputStream

Seek to the given offset from the start of the file. The next read() will be from that location. Can't seek past the end of the stream.

Overrides:

seek in class FSDataInputStreamWrapper

Parameters:

desired - the desired offset

Throws:

IOException - Thrown if an error occurred while seeking inside the input stream.

getPos

public long getPos()
            throws IOException

Description copied from class: FSDataInputStream

Gets the current position in the input stream.

Overrides:

getPos in class FSDataInputStreamWrapper

Returns:

current position in the input stream

Throws:

IOException - Thrown if an I/O error occurred in the underlying stream implementation while accessing the stream's position.

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class FSDataInputStreamWrapper

Throws:

IOException

mark

public void mark(int readlimit)

Overrides:

mark in class FSDataInputStreamWrapper

reset

public void reset()
           throws IOException

Overrides:

reset in class FSDataInputStreamWrapper

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class FSDataInputStreamWrapper