Module org.apache.jena.core

Package org.apache.jena.mem.store.indexed

Class IndexListsSpliterator

java.lang.Object

org.apache.jena.mem.store.indexed.IndexListsSpliterator

All Implemented Interfaces:

Spliterator<Triple>

public class IndexListsSpliterator
extends Object
implements Spliterator<Triple>

Spliterator counterpart to IndexListsIterator: walks the intersection of two IndexLists, dereferencing each surviving triple index against a IndexedTripleSource. Supports recursive splitting for parallel traversal; the split happens on the (smaller) list being scanned, never on the larger list (which is only probed via its reverse-index array).

Detects concurrent modifications by snapshotting triples.size() at construction time and rechecking it at each advance/forEach boundary; throws ConcurrentModificationException if the size has changed.

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	Description
IndexListsSpliterator(IndexedTripleSource source, IndexList indexListA, int[] reverseIndicesA, IndexList indexListB, int[] reverseIndicesB)	Creates a spliterator over the triples whose indices appear in both indexListA and indexListB.

Method Summary

Modifier and Type	Method	Description
int	characteristics()
long	estimateSize()
void	forEachRemaining(Consumer<? super Triple> action)
long	getExactSizeIfKnown()
boolean	tryAdvance(Consumer<? super Triple> action)
Spliterator<Triple>	trySplit()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Spliterator

getComparator, hasCharacteristics

Constructor Details

IndexListsSpliterator

public IndexListsSpliterator(IndexedTripleSource source,
 IndexList indexListA,
 int[] reverseIndicesA,
 IndexList indexListB,
 int[] reverseIndicesB)

Creates a spliterator over the triples whose indices appear in both indexListA and indexListB.

Parameters:

source - the canonical triple set

indexListA - one of the index lists to intersect

reverseIndicesA - reverse-index array for indexListA

indexListB - the other index list to intersect

reverseIndicesB - reverse-index array for indexListB

Method Details

tryAdvance

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

Specified by:

tryAdvance in interface Spliterator<Triple>

forEachRemaining

public void forEachRemaining(Consumer<? super Triple> action)

Specified by:

forEachRemaining in interface Spliterator<Triple>

trySplit

public Spliterator<Triple> trySplit()

Specified by:

trySplit in interface Spliterator<Triple>

estimateSize

public long estimateSize()

Specified by:

estimateSize in interface Spliterator<Triple>

getExactSizeIfKnown

public long getExactSizeIfKnown()

Specified by:

getExactSizeIfKnown in interface Spliterator<Triple>

characteristics

public int characteristics()

Specified by:

characteristics in interface Spliterator<Triple>