com.orientechnologies.orient.core.storage.ridbag.sbtree

Class OSBTreeRidBag

java.lang.Object

com.orientechnologies.orient.core.storage.ridbag.sbtree.OSBTreeRidBag

All Implemented Interfaces:

OSizeable, OAutoConvertToRecord, ODetachable, ORecordElement, ORecordLazyMultiValue, OTrackedMultiValue<OIdentifiable,OIdentifiable>, ORidBagDelegate, Iterable<OIdentifiable>

public class OSBTreeRidBag
extends Object
implements ORidBagDelegate

Persistent Set implementation that uses the SBTree to handle entries in persistent way.

Author:

Artem Orobets (enisher-at-gmail.com)

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.record.ORecordElement

ORecordElement.STATUS

Constructor Summary

Constructors

Constructor and Description
OSBTreeRidBag()
OSBTreeRidBag(OBonsaiCollectionPointer pointer, Map<OIdentifiable,Change> changes)

Method Summary

Modifier and Type	Method and Description
void	add(OIdentifiable identifiable)
void	addAll(Collection<OIdentifiable> values)
void	applyNewEntries()
void	clearChanges()
void	confirmDelete()
boolean	contains(OIdentifiable identifiable) THIS IS VERY EXPENSIVE METHOD AND CAN NOT BE CALLED IN REMOTE STORAGE.
void	convertLinks2Records() Browse all the set to convert all the items into records.
boolean	convertRecords2Links() Browse all the set to convert all the items into links.
void	debugPrint(PrintStream writer)
int	deserialize(byte[] stream, int offset)
boolean	detach() Detaches the object.
void	disableTracking(ORecordElement document)
void	enableTracking(ORecordElement parent)
NavigableMap<OIdentifiable,Change>	getChanges()
OBonsaiCollectionPointer	getCollectionPointer()
Class<?>	getGenericClass()
ORecordElement	getOwner()
int	getSerializedSize()
int	getSerializedSize(byte[] stream, int offset)
OMultiValueChangeTimeLine<Object,Object>	getTimeLine()
OSimpleMultiValueTracker<OIdentifiable,OIdentifiable>	getTracker()
OMultiValueChangeTimeLine<OIdentifiable,OIdentifiable>	getTransactionTimeLine()
void	handleContextSBTree(ORecordSerializationContext context, OBonsaiCollectionPointer pointer)
boolean	isAutoConvertToRecord()
boolean	isEmpty()
boolean	isModified()
boolean	isTransactionModified()
Iterator<OIdentifiable>	iterator()
void	mergeChanges(OSBTreeRidBag treeRidBag)
Iterator<OIdentifiable>	rawIterator()
void	remove(OIdentifiable identifiable)
void	replace(OMultiValueChangeEvent<Object,Object> event, Object newValue)
void	requestDelete()
Object	returnOriginalState(List<OMultiValueChangeEvent<OIdentifiable,OIdentifiable>> multiValueChangeEvents) Reverts all operations that were performed on collection and return original collection state.
int	serialize(byte[] stream, int offset, UUID ownerUuid) Writes content of bag to stream.
void	setAutoConvertToRecord(boolean convertToRecord)
void	setCollectionPointer(OBonsaiCollectionPointer collectionPointer)
<RET> RET	setDirty() Marks the instance as dirty.
void	setDirtyNoChanged()
void	setOwner(ORecordElement owner)
void	setSize(int size)
void	setTracker(OSimpleMultiValueTracker<OIdentifiable,OIdentifiable> tracker)
void	setTransactionModified(boolean transactionDirty)
int	size()
String	toString()
void	transactionClear()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface com.orientechnologies.orient.core.db.record.OTrackedMultiValue

nestedDisable, nestedEnabled, nestedTransactionClear

Constructor Detail

OSBTreeRidBag

public OSBTreeRidBag(OBonsaiCollectionPointer pointer,
                     Map<OIdentifiable,Change> changes)

OSBTreeRidBag

public OSBTreeRidBag()

Method Detail

setSize

public void setSize(int size)

Specified by:

setSize in interface ORidBagDelegate

getOwner

public ORecordElement getOwner()

Specified by:

getOwner in interface ORecordElement

Specified by:

getOwner in interface ORidBagDelegate

Returns:

Returns record element which contains given one.

setOwner

public void setOwner(ORecordElement owner)

Specified by:

setOwner in interface ORidBagDelegate

iterator

public Iterator<OIdentifiable> iterator()

Specified by:

iterator in interface Iterable<OIdentifiable>

rawIterator

public Iterator<OIdentifiable> rawIterator()

Specified by:

rawIterator in interface ORecordLazyMultiValue

convertLinks2Records

public void convertLinks2Records()

Description copied from interface: ORecordLazyMultiValue

Browse all the set to convert all the items into records.

It converts only items that already loaded into memory from storage. To convert records that will be fetched from disk later use OAutoConvertToRecord.setAutoConvertToRecord(boolean)

Specified by:

convertLinks2Records in interface ORecordLazyMultiValue

convertRecords2Links

public boolean convertRecords2Links()

Description copied from interface: ORecordLazyMultiValue

Browse all the set to convert all the items into links.

Specified by:

convertRecords2Links in interface ORecordLazyMultiValue

Returns:

mergeChanges

public void mergeChanges(OSBTreeRidBag treeRidBag)

isAutoConvertToRecord

public boolean isAutoConvertToRecord()

Specified by:

isAutoConvertToRecord in interface OAutoConvertToRecord

setAutoConvertToRecord

public void setAutoConvertToRecord(boolean convertToRecord)

Specified by:

setAutoConvertToRecord in interface OAutoConvertToRecord

detach

public boolean detach()

Description copied from interface: ODetachable

Detaches the object.

Specified by:

detach in interface ODetachable

Returns:

true if the object has been fully detached, otherwise false

addAll

public void addAll(Collection<OIdentifiable> values)

Specified by:

addAll in interface ORidBagDelegate

add

public void add(OIdentifiable identifiable)

Specified by:

add in interface ORidBagDelegate

remove

public void remove(OIdentifiable identifiable)

Specified by:

remove in interface ORidBagDelegate

contains

public boolean contains(OIdentifiable identifiable)

Description copied from interface: ORidBagDelegate

THIS IS VERY EXPENSIVE METHOD AND CAN NOT BE CALLED IN REMOTE STORAGE.

Specified by:

contains in interface ORidBagDelegate

Parameters:

identifiable - Object to check.

Returns:

true if ridbag contains at leas one instance with the same rid as passed in identifiable.

size

public int size()

Specified by:

size in interface OSizeable

toString

public String toString()

Specified by:

toString in interface ORidBagDelegate

Overrides:

toString in class Object

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface ORidBagDelegate

getGenericClass

public Class<?> getGenericClass()

Specified by:

getGenericClass in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

returnOriginalState

public Object returnOriginalState(List<OMultiValueChangeEvent<OIdentifiable,OIdentifiable>> multiValueChangeEvents)

Description copied from interface: OTrackedMultiValue

Reverts all operations that were performed on collection and return original collection state.

Specified by:

returnOriginalState in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

Parameters:

multiValueChangeEvents - List of operations that were performed on collection.

Returns:

Original collection state.

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface ORidBagDelegate

getSerializedSize

public int getSerializedSize(byte[] stream,
                             int offset)

Specified by:

getSerializedSize in interface ORidBagDelegate

handleContextSBTree

public void handleContextSBTree(ORecordSerializationContext context,
                                OBonsaiCollectionPointer pointer)

serialize

public int serialize(byte[] stream,
                     int offset,
                     UUID ownerUuid)

Description copied from interface: ORidBagDelegate

Writes content of bag to stream.

OwnerUuid is needed to notify db about changes of collection pointer if some happens during serialization.

Specified by:

serialize in interface ORidBagDelegate

Parameters:

stream - to write content

offset - in stream where start to write content

ownerUuid - id of delegate owner

Returns:

offset where content of stream is ended

applyNewEntries

public void applyNewEntries()

clearChanges

public void clearChanges()

requestDelete

public void requestDelete()

Specified by:

requestDelete in interface ORidBagDelegate

confirmDelete

public void confirmDelete()

deserialize

public int deserialize(byte[] stream,
                       int offset)

Specified by:

deserialize in interface ORidBagDelegate

getCollectionPointer

public OBonsaiCollectionPointer getCollectionPointer()

setCollectionPointer

public void setCollectionPointer(OBonsaiCollectionPointer collectionPointer)

debugPrint

public void debugPrint(PrintStream writer)
                throws IOException

Throws:

IOException

getChanges

public NavigableMap<OIdentifiable,Change> getChanges()

Specified by:

getChanges in interface ORidBagDelegate

replace

public void replace(OMultiValueChangeEvent<Object,Object> event,
                    Object newValue)

Specified by:

replace in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

enableTracking

public void enableTracking(ORecordElement parent)

Specified by:

enableTracking in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

disableTracking

public void disableTracking(ORecordElement document)

Specified by:

disableTracking in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

transactionClear

public void transactionClear()

Specified by:

transactionClear in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

isModified

public boolean isModified()

Specified by:

isModified in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

isTransactionModified

public boolean isTransactionModified()

Specified by:

isTransactionModified in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

getTimeLine

public OMultiValueChangeTimeLine<Object,Object> getTimeLine()

Specified by:

getTimeLine in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

setDirty

public <RET> RET setDirty()

Description copied from interface: ORecordElement

Marks the instance as dirty. The dirty status could be propagated up if the implementation supports ownership concept.

Specified by:

setDirty in interface ORecordElement

Returns:

The object it self. Useful to call methods in chain.

setTransactionModified

public void setTransactionModified(boolean transactionDirty)

Specified by:

setTransactionModified in interface ORidBagDelegate

setDirtyNoChanged

public void setDirtyNoChanged()

Specified by:

setDirtyNoChanged in interface ORecordElement

getTracker

public OSimpleMultiValueTracker<OIdentifiable,OIdentifiable> getTracker()

Specified by:

getTracker in interface ORidBagDelegate

setTracker

public void setTracker(OSimpleMultiValueTracker<OIdentifiable,OIdentifiable> tracker)

Specified by:

setTracker in interface ORidBagDelegate

getTransactionTimeLine

public OMultiValueChangeTimeLine<OIdentifiable,OIdentifiable> getTransactionTimeLine()

Specified by:

getTransactionTimeLine in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>