tdl.record.sourcecode.snapshot.file

Class Reader

java.lang.Object

tdl.record.sourcecode.snapshot.file.Reader

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.Iterator<java.lang.Integer>

public class Reader
extends java.lang.Object
implements java.util.Iterator<java.lang.Integer>, java.lang.AutoCloseable

Constructor Summary

Constructors

Constructor and Description
Reader(java.io.File file)

Method Summary

Modifier and Type	Method and Description
void	close()
void	forEachRemaining(java.util.function.Consumer<? super java.lang.Integer> action)
java.io.File	getFile()
Header	getFileHeader()
long	getFilePointer()
int	getFirstKeySnapshotBefore(int index)
int	getIndexBeforeOrEqualsTimestamp(long timestamp)
java.util.List<Segment>	getReplayableSnapshotSegmentsUntil(int index)
java.util.List<java.lang.Integer>	getSegmentAddresses()
Segment	getSnapshotAt(int index)
java.util.List<Segment>	getSnapshots()
java.util.List<Segment>	getSnapshotSegmentsByRange(int start, int end)
boolean	hasNext()
java.lang.Integer	next()
Segment	nextSegment()
Segment	readSegmentByAddress(int address)
void	remove()
void	reset()
void	skip()

Methods inherited from class java.lang.Object

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

Constructor Detail

Reader

public Reader(java.io.File file)
       throws java.io.FileNotFoundException,
              java.io.IOException

Throws:

java.io.FileNotFoundException

java.io.IOException

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<java.lang.Integer>

next

public java.lang.Integer next()

Specified by:

next in interface java.util.Iterator<java.lang.Integer>

nextSegment

public Segment nextSegment()
                    throws java.io.IOException

Throws:

java.io.IOException

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<java.lang.Integer>

forEachRemaining

public void forEachRemaining(java.util.function.Consumer<? super java.lang.Integer> action)

Specified by:

forEachRemaining in interface java.util.Iterator<java.lang.Integer>

reset

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

Throws:

java.io.IOException

getFilePointer

public long getFilePointer()

getFileHeader

public Header getFileHeader()

skip

public void skip()
          throws java.io.IOException

Throws:

java.io.IOException

getSegmentAddresses

public java.util.List<java.lang.Integer> getSegmentAddresses()
                                                      throws java.io.IOException

Throws:

java.io.IOException

getReplayableSnapshotSegmentsUntil

public java.util.List<Segment> getReplayableSnapshotSegmentsUntil(int index)
                                                           throws java.lang.Exception

Parameters:

index - Inclusive.

Returns:

Throws:

java.lang.Exception

getSnapshotSegmentsByRange

public java.util.List<Segment> getSnapshotSegmentsByRange(int start,
                                                          int end)
                                                   throws java.io.IOException

Parameters:

start - inclusive.

end - exclusive.

Returns:

Throws:

java.io.IOException

getFirstKeySnapshotBefore

public int getFirstKeySnapshotBefore(int index)
                              throws java.io.IOException

Throws:

java.io.IOException

readSegmentByAddress

public Segment readSegmentByAddress(int address)
                             throws java.io.IOException

Throws:

java.io.IOException

getSnapshotAt

public Segment getSnapshotAt(int index)
                      throws java.io.IOException

Throws:

java.io.IOException

getSnapshots

public java.util.List<Segment> getSnapshots()
                                     throws java.io.IOException

Throws:

java.io.IOException

getIndexBeforeOrEqualsTimestamp

public int getIndexBeforeOrEqualsTimestamp(long timestamp)
                                    throws java.io.IOException

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

getFile

public java.io.File getFile()