org.apache.ignite.internal.processors.hadoop.impl.igfs

Class HadoopIgfsSecondaryFileSystemPositionedReadable

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsSecondaryFileSystemPositionedReadable

All Implemented Interfaces:

Closeable, AutoCloseable, IgfsSecondaryFileSystemPositionedReadable

public class HadoopIgfsSecondaryFileSystemPositionedReadable
extends Object
implements IgfsSecondaryFileSystemPositionedReadable

Secondary file system input stream wrapper which actually opens input stream only in case it is explicitly requested.

The class is expected to be used only from synchronized context and therefore is not tread-safe.

Constructor Summary

Constructors

Constructor and Description
HadoopIgfsSecondaryFileSystemPositionedReadable(FileSystem fs, Path path, int bufSize) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close() Close wrapped input stream in case it was previously opened.
int	read(long pos, byte[] buf, int off, int len)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopIgfsSecondaryFileSystemPositionedReadable

public HadoopIgfsSecondaryFileSystemPositionedReadable(FileSystem fs,
                                                       Path path,
                                                       int bufSize)

Constructor.

Parameters:

fs - Secondary file system.

path - Path to the file to open.

bufSize - Buffer size.

Method Detail

close

public void close()

Close wrapped input stream in case it was previously opened.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

read

public int read(long pos,
                byte[] buf,
                int off,
                int len)
         throws IOException

Specified by:

read in interface IgfsSecondaryFileSystemPositionedReadable

Throws:

IOException