Package org.apache.cassandra.db.commitlog

Class CommitLogSegmentReader

java.lang.Object

org.apache.cassandra.db.commitlog.CommitLogSegmentReader

All Implemented Interfaces:

Iterable<CommitLogSegmentReader.SyncSegment>

public class CommitLogSegmentReader
extends Object
implements Iterable<CommitLogSegmentReader.SyncSegment>

Read each sync section of a commit log, iteratively.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	CommitLogSegmentReader.SegmentIterator
static class	CommitLogSegmentReader.SegmentReadException
static class	CommitLogSegmentReader.SyncSegment

Field Summary

Fields

Modifier and Type	Field	Description
protected int	end	ending position of the current sync section.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CommitLogSegmentReader(CommitLogReadHandler handler, CommitLogDescriptor descriptor, RandomAccessReader reader, boolean tolerateTruncation)

Method Summary

Modifier and Type	Method	Description
Iterator<CommitLogSegmentReader.SyncSegment>	iterator()
static void	setAllowSkipSyncMarkerCrc(boolean allow)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

end

protected int end

ending position of the current sync section.

Constructor Details

CommitLogSegmentReader

protected CommitLogSegmentReader(CommitLogReadHandler handler,
 CommitLogDescriptor descriptor,
 RandomAccessReader reader,
 boolean tolerateTruncation)

Method Details

setAllowSkipSyncMarkerCrc

public static void setAllowSkipSyncMarkerCrc(boolean allow)

iterator

public Iterator<CommitLogSegmentReader.SyncSegment> iterator()

Specified by:

iterator in interface Iterable<CommitLogSegmentReader.SyncSegment>