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, 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)

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	addChangeListener(OMultiValueChangeListener<OIdentifiable,OIdentifiable> changeListener) Add change listener.
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	fireCollectionChangedEvent(OMultiValueChangeEvent<OIdentifiable,OIdentifiable> event)
List<OMultiValueChangeListener<OIdentifiable,OIdentifiable>>	getChangeListeners()
NavigableMap<OIdentifiable,Change>	getChanges()
OBonsaiCollectionPointer	getCollectionPointer()
Class<?>	getGenericClass()
ORecord	getOwner()
int	getSerializedSize()
int	getSerializedSize(byte[] stream, int offset)
void	handleContextSBTree(ORecordSerializationContext context, OBonsaiCollectionPointer pointer)
boolean	isAutoConvertToRecord()
boolean	isEmpty()
Iterator<OIdentifiable>	iterator()
void	mergeChanges(OSBTreeRidBag treeRidBag)
Iterator<OIdentifiable>	rawIterator()
void	remove(OIdentifiable identifiable)
void	removeRecordChangeListener(OMultiValueChangeListener<OIdentifiable,OIdentifiable> changeListener) Remove change listener.
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)
void	setOwner(ORecord owner)
void	setSize(int size)
int	size()
String	toString()

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

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 ORecord getOwner()

Specified by:

getOwner in interface ORidBagDelegate

setOwner

public void setOwner(ORecord 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

addChangeListener

public void addChangeListener(OMultiValueChangeListener<OIdentifiable,OIdentifiable> changeListener)

Description copied from interface: OTrackedMultiValue

Add change listener.

Specified by:

addChangeListener in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

Parameters:

changeListener - Change listener instance.

removeRecordChangeListener

public void removeRecordChangeListener(OMultiValueChangeListener<OIdentifiable,OIdentifiable> changeListener)

Description copied from interface: OTrackedMultiValue

Remove change listener.

Specified by:

removeRecordChangeListener in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

Parameters:

changeListener - Change listener instance.

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)

getChangeListeners

public List<OMultiValueChangeListener<OIdentifiable,OIdentifiable>> getChangeListeners()

Specified by:

getChangeListeners in interface ORidBagDelegate

fireCollectionChangedEvent

public void fireCollectionChangedEvent(OMultiValueChangeEvent<OIdentifiable,OIdentifiable> event)

Specified by:

fireCollectionChangedEvent in interface OTrackedMultiValue<OIdentifiable,OIdentifiable>

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>