public class SegmentEntityIterator<T extends java.io.Serializable> extends java.lang.Object implements java.util.Iterator<BlueEntity<T>>, java.io.Closeable
Constructor and Description |
---|
SegmentEntityIterator(Segment<T> segment,
long rangeMin,
long rangeMax) |
SegmentEntityIterator(Segment<T> segment,
long highestGroupingNumberCompleted,
long rangeMin,
long rangeMax) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected static <X extends java.io.Serializable> |
extractMaxGroupingNumber(BlueObjectInput<BlueEntity<X>> input) |
protected java.util.LinkedList<Range> |
filesToRanges(java.util.List<java.io.File> files) |
protected java.nio.file.Path |
getCurrentPath() |
protected BlueObjectInput<BlueEntity<T>> |
getNextStream() |
Segment<T> |
getSegment() |
boolean |
hasNext() |
BlueEntity<T> |
next() |
protected BlueEntity<T> |
nextFromFile() |
public SegmentEntityIterator(Segment<T> segment, long highestGroupingNumberCompleted, long rangeMin, long rangeMax)
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
public boolean hasNext()
hasNext
in interface java.util.Iterator<BlueEntity<T extends java.io.Serializable>>
public BlueEntity<T> next()
next
in interface java.util.Iterator<BlueEntity<T extends java.io.Serializable>>
protected BlueEntity<T> nextFromFile()
protected BlueObjectInput<BlueEntity<T>> getNextStream()
protected java.nio.file.Path getCurrentPath()
protected java.util.LinkedList<Range> filesToRanges(java.util.List<java.io.File> files)
protected static <X extends java.io.Serializable> long extractMaxGroupingNumber(BlueObjectInput<BlueEntity<X>> input)