org.archive.util.binsearch

Class AbstractSeekableLineReader

java.lang.Object

org.archive.util.binsearch.AbstractSeekableLineReader

All Implemented Interfaces:

SeekableLineReader

Direct Known Subclasses:

HDFSSeekableLineReader, HTTPSeekableLineReader, MappedSeekableLineReader, NIOSeekableLineReader, RandomAccessFileSeekableLineReader

public abstract class AbstractSeekableLineReader
extends Object
implements SeekableLineReader

Field Summary

Fields

Modifier and Type	Field and Description
protected int	blockSize
protected BufferedReader	br
protected boolean	bufferFully
protected boolean	closed
protected InputStream	is
static Charset	UTF8

Constructor Summary

Constructors

Constructor and Description
AbstractSeekableLineReader()
AbstractSeekableLineReader(int blockSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected abstract void	doClose()
protected abstract InputStream	doSeekLoad(long offset, int maxLength)
void	finalize()
InputStream	getInputStream()
long	getSize()
boolean	isClosed()
String	readLine()
void	seek(long offset)
void	seekWithMaxRead(long offset, boolean gzip, int maxLength)
void	setBufferFully(boolean fully)
void	skipLine()

Methods inherited from class java.lang.Object

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

Field Detail

UTF8

public static final Charset UTF8

blockSize

protected int blockSize

closed

protected boolean closed

bufferFully

protected boolean bufferFully

br

protected BufferedReader br

is

protected InputStream is

Constructor Detail

AbstractSeekableLineReader

public AbstractSeekableLineReader()

AbstractSeekableLineReader

public AbstractSeekableLineReader(int blockSize)

Method Detail

seek

public void seek(long offset)
          throws IOException

Specified by:

seek in interface SeekableLineReader

Throws:

IOException

seekWithMaxRead

public void seekWithMaxRead(long offset,
                   boolean gzip,
                   int maxLength)
                     throws IOException

Specified by:

seekWithMaxRead in interface SeekableLineReader

Throws:

IOException

doSeekLoad

protected abstract InputStream doSeekLoad(long offset,
                     int maxLength)
                                   throws IOException

Throws:

IOException

doClose

protected abstract void doClose()
                         throws IOException

Throws:

IOException

getInputStream

public InputStream getInputStream()

Specified by:

getInputStream in interface SeekableLineReader

skipLine

public void skipLine()
              throws IOException

Specified by:

skipLine in interface SeekableLineReader

Throws:

IOException

readLine

public String readLine()
                throws IOException

Specified by:

readLine in interface SeekableLineReader

Throws:

IOException

close

public final void close()
                 throws IOException

Specified by:

close in interface SeekableLineReader

Throws:

IOException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface SeekableLineReader

getSize

public long getSize()
             throws IOException

Specified by:

getSize in interface SeekableLineReader

Throws:

IOException

setBufferFully

public void setBufferFully(boolean fully)

Specified by:

setBufferFully in interface SeekableLineReader

finalize

public void finalize()

Overrides:

finalize in class Object