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 java.lang.Object
implements SeekableLineReader

Field Summary

Fields

Modifier and Type	Field and Description
protected int	blockSize
protected java.io.BufferedReader	br
protected boolean	bufferFully
protected boolean	closed
protected java.io.InputStream	is
static java.nio.charset.Charset	UTF8

Constructor Summary

Constructors

Constructor and Description
AbstractSeekableLineReader()
AbstractSeekableLineReader(int blockSize)

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract void	doClose()
protected abstract java.io.InputStream	doSeekLoad(long offset, int maxLength)
void	finalize()
java.io.InputStream	getInputStream()
long	getSize()
boolean	isClosed()
java.lang.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 java.nio.charset.Charset UTF8

blockSize

protected int blockSize

closed

protected boolean closed

bufferFully

protected boolean bufferFully

br

protected java.io.BufferedReader br

is

protected java.io.InputStream is

Constructor Detail

AbstractSeekableLineReader

public AbstractSeekableLineReader()

AbstractSeekableLineReader

public AbstractSeekableLineReader(int blockSize)

Method Detail

seek

public void seek(long offset)
          throws java.io.IOException

Specified by:

seek in interface SeekableLineReader

Throws:

java.io.IOException

seekWithMaxRead

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

Specified by:

seekWithMaxRead in interface SeekableLineReader

Throws:

java.io.IOException

doSeekLoad

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

Throws:

java.io.IOException

doClose

protected abstract void doClose()
                         throws java.io.IOException

Throws:

java.io.IOException

getInputStream

public java.io.InputStream getInputStream()

Specified by:

getInputStream in interface SeekableLineReader

skipLine

public void skipLine()
              throws java.io.IOException

Specified by:

skipLine in interface SeekableLineReader

Throws:

java.io.IOException

readLine

public java.lang.String readLine()
                          throws java.io.IOException

Specified by:

readLine in interface SeekableLineReader

Throws:

java.io.IOException

close

public final void close()
                 throws java.io.IOException

Specified by:

close in interface SeekableLineReader

Throws:

java.io.IOException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface SeekableLineReader

getSize

public long getSize()
             throws java.io.IOException

Specified by:

getSize in interface SeekableLineReader

Throws:

java.io.IOException

setBufferFully

public void setBufferFully(boolean fully)

Specified by:

setBufferFully in interface SeekableLineReader

finalize

public void finalize()

Overrides:

finalize in class java.lang.Object