com.bigdata.rdf.inf

Class OwlSameAsPropertiesExpandingIterator

java.lang.Object

com.bigdata.rdf.inf.OwlSameAsPropertiesExpandingIterator

All Implemented Interfaces:

IChunkedIterator<ISPO>, IChunkedOrderedIterator<ISPO>, ICloseable, ICloseableIterator<ISPO>, Iterator<ISPO>

public class OwlSameAsPropertiesExpandingIterator
extends Object
implements IChunkedOrderedIterator<ISPO>

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Fields inherited from interface com.bigdata.striterator.IChunkedIterator

DEFAULT_CHUNK_SIZE

Constructor Summary

Constructors

Constructor and Description
OwlSameAsPropertiesExpandingIterator(IV s, IV p, IV o, AbstractTripleStore db, IV sameAs, IKeyOrder<ISPO> keyOrder)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the iterator, releasing any associated resources.
IKeyOrder<ISPO>	getKeyOrder() The natural order in which elements are being visited.
boolean	hasNext()
ISPO	next() The next element available from the iterator.
ISPO[]	nextChunk() Return the next "chunk" from the iterator.
ISPO[]	nextChunk(IKeyOrder<ISPO> keyOrder) Return the next "chunk" of elements.
void	remove() Removes the last element visited by IChunkedIterator.next() (optional operation).

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Constructor Detail

OwlSameAsPropertiesExpandingIterator

public OwlSameAsPropertiesExpandingIterator(IV s,
                                    IV p,
                                    IV o,
                                    AbstractTripleStore db,
                                    IV sameAs,
                                    IKeyOrder<ISPO> keyOrder)

Method Detail

getKeyOrder

public IKeyOrder<ISPO> getKeyOrder()

Description copied from interface: IChunkedOrderedIterator

The natural order in which elements are being visited.

Specified by:

getKeyOrder in interface IChunkedOrderedIterator<ISPO>

Returns:

The natural order in which the elements are being visited -or- null if not known.

nextChunk

public ISPO[] nextChunk()

Description copied from interface: IChunkedIterator

Return the next "chunk" from the iterator.

Specified by:

nextChunk in interface IChunkedIterator<ISPO>

Returns:

The next chunk.

nextChunk

public ISPO[] nextChunk(IKeyOrder<ISPO> keyOrder)

Description copied from interface: IChunkedOrderedIterator

Return the next "chunk" of elements. The elements will be in the specified order. If IChunkedOrderedIterator.getKeyOrder() would return non-null and the request order corresponds to the value that would be returned by IChunkedOrderedIterator.getKeyOrder() then the elements in the next chunk are NOT sorted. Otherwise the elements in the next chunk are sorted before they are returned. The size of the chunk is up to the implementation.

Specified by:

nextChunk in interface IChunkedOrderedIterator<ISPO>

Parameters:

keyOrder - The natural order for the elements in the chunk.

Returns:

The next chunk of elements in the specified order.

next

public ISPO next()

Description copied from interface: IChunkedIterator

The next element available from the iterator.

Specified by:

next in interface IChunkedIterator<ISPO>

Specified by:

next in interface Iterator<ISPO>

remove

public void remove()

Description copied from interface: IChunkedIterator

Removes the last element visited by IChunkedIterator.next() (optional operation).

Note: This method is not readily suited for use with IChunkedIterator.nextChunk() since the latter has already visited everything in the chunk and IChunkedIterator.remove() would only remove the last item in the chunk. Normally you will want to accumulate items to be removed in a buffer and then submit the buffer to some batch api operation when it overflows. Alternatively, the IRangeQuery.REMOVEALL flag may be used with the source iterator to remove elements from the index as they are visited.

Specified by:

remove in interface IChunkedIterator<ISPO>

Specified by:

remove in interface Iterator<ISPO>

close

public void close()

Description copied from interface: ICloseableIterator

Closes the iterator, releasing any associated resources. This method MAY be invoked safely if the iterator is already closed. Implementations of this interface MUST invoke ICloseableIterator.close() if Iterator.hasNext() method returns false to ensure that the iterator is closed (and its resources release) as soon as it is exhausted.

Note: Implementations that support Iterator.remove() MUST NOT eagerly close the iterator when it is exhausted since that would make it impossible to remove the last visited statement. Instead they MUST wait for an explicit ICloseableIterator.close() by the application.

Specified by:

close in interface ICloseable

Specified by:

close in interface ICloseableIterator<ISPO>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<ISPO>