net.sansa_stack.hadoop.util

Class SeekableInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.apache.commons.io.input.ProxyInputStream

net.sansa_stack.hadoop.util.SeekableInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, SeekableDecorator, org.apache.hadoop.fs.Seekable

public class SeekableInputStream
extends org.apache.commons.io.input.ProxyInputStream
implements SeekableDecorator

Combines Hadoop's Seekable and InputStream into one class

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.fs.Seekable	seekable

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
SeekableInputStream(InputStream proxy, org.apache.hadoop.fs.Seekable seekable) Constructs a new ProxyInputStream.

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.fs.Seekable	getSeekable()

Methods inherited from class org.apache.commons.io.input.ProxyInputStream

afterRead, available, beforeRead, close, handleIOException, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sansa_stack.hadoop.util.SeekableDecorator

getPos, seek, seekToNewSource

Field Detail

seekable

protected org.apache.hadoop.fs.Seekable seekable

Constructor Detail

SeekableInputStream

public SeekableInputStream(InputStream proxy,
                           org.apache.hadoop.fs.Seekable seekable)

Constructs a new ProxyInputStream.

Parameters:

proxy - the InputStream to delegate to

Method Detail

getSeekable

public org.apache.hadoop.fs.Seekable getSeekable()

Specified by:

getSeekable in interface SeekableDecorator