com.orientechnologies.orient.core.index

Class OIndexChangesWrapper

java.lang.Object

com.orientechnologies.orient.core.index.OIndexChangesWrapper

All Implemented Interfaces:

OIndexCursor, Iterator<OIdentifiable>

public class OIndexChangesWrapper
extends Object
implements OIndexCursor

Wrapper which is used to detect whether the cursor is working with index which is being rebuilt at the moment.

If such situation is detected any call to any method throws OIndexIsRebuildingException

See Also:

OIndexAbstract.getRebuildVersion()

Field Summary

Fields

Modifier and Type	Field and Description
protected OIndexCursor	delegate
protected long	indexRebuildVersion
protected OIndex<?>	source

Constructor Summary

Constructors

Constructor and Description
OIndexChangesWrapper(OIndex<?> source, OIndexCursor delegate, long indexRebuildVersion)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
OIdentifiable	next()
Map.Entry<Object,OIdentifiable>	nextEntry() Returns nextEntry element in subset of index data which should be iterated by given cursor.
void	remove()
void	setPrefetchSize(int prefetchSize) Set number of records to fetch for the next call to next() or nextEntry().
protected void	throwRebuildException()
Set<Map.Entry<Object,OIdentifiable>>	toEntries() Accumulates and returns all entries of index inside of data subset of cursor.
Set<Object>	toKeys() Accumulates and returns all keys of index inside of data subset of cursor.
Set<OIdentifiable>	toValues() Accumulates and returns all values of index inside of data subset of cursor.
static OIndexCursor	wrap(OIndex<?> source, OIndexCursor cursor, long indexRebuildVersion) Wraps courser only if it is not already wrapped.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

source

protected final OIndex<?> source

delegate

protected final OIndexCursor delegate

indexRebuildVersion

protected final long indexRebuildVersion

Constructor Detail

OIndexChangesWrapper

public OIndexChangesWrapper(OIndex<?> source,
                            OIndexCursor delegate,
                            long indexRebuildVersion)

Method Detail

wrap

public static OIndexCursor wrap(OIndex<?> source,
                                OIndexCursor cursor,
                                long indexRebuildVersion)

Wraps courser only if it is not already wrapped.

Parameters:

source - Index which is used to create given cursor.

cursor - Cursor to wrap.

indexRebuildVersion - Rebuild version of index before cursor was created.

Returns:

Wrapped cursor.

See Also:

OIndex.getRebuildVersion()

remove

public void remove()

Specified by:

remove in interface Iterator<OIdentifiable>

nextEntry

public Map.Entry<Object,OIdentifiable> nextEntry()

Returns nextEntry element in subset of index data which should be iterated by given cursor.

Specified by:

nextEntry in interface OIndexCursor

Returns:

nextEntry element in subset of index data which should be iterated by given cursor or null if all data are iterated.

toValues

public Set<OIdentifiable> toValues()

Accumulates and returns all values of index inside of data subset of cursor.

Specified by:

toValues in interface OIndexCursor

Returns:

all values of index inside of data subset of cursor.

toEntries

public Set<Map.Entry<Object,OIdentifiable>> toEntries()

Accumulates and returns all entries of index inside of data subset of cursor.

Specified by:

toEntries in interface OIndexCursor

Returns:

all entries of index inside of data subset of cursor.

toKeys

public Set<Object> toKeys()

Accumulates and returns all keys of index inside of data subset of cursor.

Specified by:

toKeys in interface OIndexCursor

Returns:

all keys of index inside of data subset of cursor.

setPrefetchSize

public void setPrefetchSize(int prefetchSize)

Set number of records to fetch for the next call to next() or nextEntry().

Specified by:

setPrefetchSize in interface OIndexCursor

Parameters:

prefetchSize - Number of records to prefetch. -1 = prefetch using default settings.

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<OIdentifiable>

next

public OIdentifiable next()

Specified by:

next in interface Iterator<OIdentifiable>

throwRebuildException

protected void throwRebuildException()