org.corfudb.runtime.view.stream

Class StreamSpliterator

java.lang.Object

java.util.Spliterators.AbstractSpliterator<ILogData>

org.corfudb.runtime.view.stream.StreamSpliterator

All Implemented Interfaces:

Spliterator<ILogData>

public class StreamSpliterator
extends Spliterators.AbstractSpliterator<ILogData>

A spliterator for streams, which supports limiting the spliterator's scope to a maximum global address.

This spliterator is guaranteed to never read PAST the maximum global address given. This is necessary because reading from a stream MODIFIES the stream pointer, and streams provide the guarantee that they will return entries in order exactly once.

Concurrent modification of the stream during iteration is NOT supported.

Created by mwei on 4/24/17.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Spliterator

Spliterator.OfDouble, Spliterator.OfInt, Spliterator.OfLong, Spliterator.OfPrimitive<T,T_CONS,T_SPLITR extends Spliterator.OfPrimitive<T,T_CONS,T_SPLITR>>

Field Summary

Fields inherited from interface java.util.Spliterator

CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED

Constructor Summary

Constructors

Constructor and Description
StreamSpliterator(IStreamView view) Construct a stream spliterator with the given view and no limit.
StreamSpliterator(IStreamView view, long maxGlobal) Construct a stream spliterator with the given view and limit

Method Summary

Modifier and Type	Method and Description
Comparator<? super ILogData>	getComparator()
boolean	tryAdvance(Consumer<? super ILogData> action)

Methods inherited from class java.util.Spliterators.AbstractSpliterator

characteristics, estimateSize, trySplit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Spliterator

forEachRemaining, getExactSizeIfKnown, hasCharacteristics

Constructor Detail

StreamSpliterator

public StreamSpliterator(IStreamView view)

Construct a stream spliterator with the given view and no limit.

Parameters:

view - The view to construct the spliterator with.

StreamSpliterator

public StreamSpliterator(IStreamView view,
                         long maxGlobal)

Construct a stream spliterator with the given view and limit

Parameters:

view - The view to construct the spliterator with.

maxGlobal - The maximum global address to limit reads up to.

Method Detail

tryAdvance

public boolean tryAdvance(Consumer<? super ILogData> action)

getComparator

public Comparator<? super ILogData> getComparator()