Package edu.stanford.slac.archiverappliance.PB.utils

Class ReverseLineByteStream

java.lang.Object

edu.stanford.slac.archiverappliance.PB.utils.ReverseLineByteStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class ReverseLineByteStream
extends Object
implements Closeable

A modification of LineByteStream optimized for reading a PB chunk backwards in time Based off of dpetruha's answer here - https://stackoverflow.com/questions/8664705/how-to-read-file-from-end-to-start-in-reverse-order-in-java

Author:

mshankar

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_LINE_SIZE

Constructor Summary

Constructors

Constructor	Description
ReverseLineByteStream(Path path)
ReverseLineByteStream(Path path, long startPosition, long endPosition)

Method Summary

Modifier and Type	Method	Description
void	close()
String	getAbsolutePath()
long	getTotalBytesRead()	Mainly used in the unit tests
boolean	readLine(ByteArray bar)
void	safeClose()
void	seekToBeforePreviousLine(long posn)

Methods inherited from class java.lang.Object

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

Field Details

MAX_LINE_SIZE

public static final int MAX_LINE_SIZE

See Also:

• Constant Field Values

Constructor Details

ReverseLineByteStream

public ReverseLineByteStream(Path path)
                      throws IOException

Throws:

IOException

ReverseLineByteStream

public ReverseLineByteStream(Path path,
 long startPosition,
 long endPosition)
                      throws IOException

Throws:

IOException

Method Details

seekToBeforePreviousLine

public void seekToBeforePreviousLine(long posn)
                              throws IOException

Throws:

IOException

readLine

public boolean readLine(ByteArray bar)
                 throws IOException

Throws:

IOException

safeClose

public void safeClose()

getAbsolutePath

public String getAbsolutePath()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getTotalBytesRead

public long getTotalBytesRead()

Mainly used in the unit tests