com.orientechnologies.orient.core.index.sbtreebonsai.local

Class OSBTreeBonsaiLocal<K,V>

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAdaptive

com.orientechnologies.orient.core.storage.impl.local.paginated.base.ODurableComponent

com.orientechnologies.orient.core.index.sbtreebonsai.local.OSBTreeBonsaiLocal<K,V>

All Implemented Interfaces:

OTreeInternal<K,V>, OSBTreeBonsai<K,V>

public class OSBTreeBonsaiLocal<K,V>
extends ODurableComponent
implements OSBTreeBonsai<K,V>

Tree-based dictionary algorithm. Similar to OSBTree but uses subpages of disk cache that is more efficient for small data structures.

Oriented for usage of several instances inside of one file.

Creation of several instances that represent the same collection is not allowed.

Since:

1.6.0

Author:

Andrey Lomakin, Artem Orobets

See Also:

OSBTree

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.index.sbtree.OTreeInternal

OTreeInternal.AccumulativeListener<K,V>, OTreeInternal.RangeResultListener<K,V>

Field Summary

Fields inherited from class com.orientechnologies.orient.core.storage.impl.local.paginated.base.ODurableComponent

atomicOperationsManager, extension, performanceStatisticManager, readCache, storage, writeCache

Constructor Summary

Constructors

Constructor and Description
OSBTreeBonsaiLocal(String name, String dataFileExtension, OAbstractPaginatedStorage storage)

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all entries from bonsai tree.
void	close()
void	close(boolean flush)
void	create(OBinarySerializer<K> keySerializer, OBinarySerializer<V> valueSerializer)
void	debugPrintBucket(OBonsaiBucketPointer bucketPointer, PrintStream writer, ArrayList<OBonsaiBucketPointer> path)
void	debugPrintBucket(PrintStream writer)
void	delete() Deletes a whole tree.
K	firstKey()
void	flush()
V	get(K key) Search for entry with specific key and return its value.
OBonsaiCollectionPointer	getCollectionPointer()
long	getFileId() Gets id of file where this bonsai tree is stored.
OBinarySerializer<K>	getKeySerializer()
int	getRealBagSize(Map<K,OSBTreeRidBag.Change> changes) Hardcoded method for Bag to avoid creation of extra layer.
OBonsaiBucketPointer	getRootBucketPointer()
Collection<V>	getValuesBetween(K keyFrom, boolean fromInclusive, K keyTo, boolean toInclusive, int maxValuesToFetch)
OBinarySerializer<V>	getValueSerializer()
Collection<V>	getValuesMajor(K key, boolean inclusive, int maxValuesToFetch)
Collection<V>	getValuesMinor(K key, boolean inclusive, int maxValuesToFetch)
K	lastKey()
boolean	load(OBonsaiBucketPointer rootBucketPointer)
void	loadEntriesBetween(K keyFrom, boolean fromInclusive, K keyTo, boolean toInclusive, OTreeInternal.RangeResultListener<K,V> listener)
void	loadEntriesMajor(K key, boolean inclusive, boolean ascSortOrder, OTreeInternal.RangeResultListener<K,V> listener) Load all entries with key greater then specified key.
void	loadEntriesMinor(K key, boolean inclusive, OTreeInternal.RangeResultListener<K,V> listener)
boolean	put(K key, V value)
V	remove(K key)
long	size()
protected void	startOperation()

Methods inherited from class com.orientechnologies.orient.core.storage.impl.local.paginated.base.ODurableComponent

acquireExclusiveLock, addFile, addPage, completeOperation, deleteFile, endAtomicOperation, getChanges, getExtension, getFilledUpTo, getFullName, getLockName, getName, isFileExists, isFileExists, loadPage, loadPage, openFile, pinPage, releasePage, setName, startAtomicOperation, truncateFile

Methods inherited from class com.orientechnologies.common.concur.resource.OSharedResourceAdaptive

acquireSharedLock, addUser, assertExclusiveLockHold, assertSharedLockHold, getUsers, isConcurrent, releaseExclusiveLock, releaseSharedLock, removeUser, tryAcquireExclusiveLock, tryAcquireSharedLock

Methods inherited from class java.lang.Object

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

Constructor Detail

OSBTreeBonsaiLocal

public OSBTreeBonsaiLocal(String name,
                          String dataFileExtension,
                          OAbstractPaginatedStorage storage)

Method Detail

create

public void create(OBinarySerializer<K> keySerializer,
                   OBinarySerializer<V> valueSerializer)

getFileId

public long getFileId()

Description copied from interface: OSBTreeBonsai

Gets id of file where this bonsai tree is stored.

Specified by:

getFileId in interface OSBTreeBonsai<K,V>

Returns:

id of file in OReadCache

getRootBucketPointer

public OBonsaiBucketPointer getRootBucketPointer()

Specified by:

getRootBucketPointer in interface OSBTreeBonsai<K,V>

Returns:

the pointer to the root bucket in tree.

getCollectionPointer

public OBonsaiCollectionPointer getCollectionPointer()

Specified by:

getCollectionPointer in interface OSBTreeBonsai<K,V>

Returns:

pointer to a collection.

get

public V get(K key)

Description copied from interface: OSBTreeBonsai

Search for entry with specific key and return its value.

Specified by:

get in interface OSBTreeBonsai<K,V>

Returns:

value associated with given key, NULL if no value is associated.

put

public boolean put(K key,
                   V value)

Specified by:

put in interface OSBTreeBonsai<K,V>

close

public void close(boolean flush)

close

public void close()

clear

public void clear()

Removes all entries from bonsai tree. Put all but the root page to free list for further reuse.

Specified by:

clear in interface OSBTreeBonsai<K,V>

delete

public void delete()

Deletes a whole tree. Puts all its pages to free list for further reusage.

Specified by:

delete in interface OSBTreeBonsai<K,V>

load

public boolean load(OBonsaiBucketPointer rootBucketPointer)

size

public long size()

Specified by:

size in interface OTreeInternal<K,V>

Specified by:

size in interface OSBTreeBonsai<K,V>

remove

public V remove(K key)

Specified by:

remove in interface OTreeInternal<K,V>

Specified by:

remove in interface OSBTreeBonsai<K,V>

getValuesMinor

public Collection<V> getValuesMinor(K key,
                                    boolean inclusive,
                                    int maxValuesToFetch)

Specified by:

getValuesMinor in interface OSBTreeBonsai<K,V>

loadEntriesMinor

public void loadEntriesMinor(K key,
                             boolean inclusive,
                             OTreeInternal.RangeResultListener<K,V> listener)

Specified by:

loadEntriesMinor in interface OSBTreeBonsai<K,V>

getValuesMajor

public Collection<V> getValuesMajor(K key,
                                    boolean inclusive,
                                    int maxValuesToFetch)

Specified by:

getValuesMajor in interface OSBTreeBonsai<K,V>

loadEntriesMajor

public void loadEntriesMajor(K key,
                             boolean inclusive,
                             boolean ascSortOrder,
                             OTreeInternal.RangeResultListener<K,V> listener)

Load all entries with key greater then specified key.

Specified by:

loadEntriesMajor in interface OTreeInternal<K,V>

Specified by:

loadEntriesMajor in interface OSBTreeBonsai<K,V>

Parameters:

key - defines

inclusive - if true entry with given key is included

ascSortOrder -

listener -

getValuesBetween

public Collection<V> getValuesBetween(K keyFrom,
                                      boolean fromInclusive,
                                      K keyTo,
                                      boolean toInclusive,
                                      int maxValuesToFetch)

Specified by:

getValuesBetween in interface OSBTreeBonsai<K,V>

firstKey

public K firstKey()

Specified by:

firstKey in interface OTreeInternal<K,V>

Specified by:

firstKey in interface OSBTreeBonsai<K,V>

lastKey

public K lastKey()

Specified by:

lastKey in interface OSBTreeBonsai<K,V>

loadEntriesBetween

public void loadEntriesBetween(K keyFrom,
                               boolean fromInclusive,
                               K keyTo,
                               boolean toInclusive,
                               OTreeInternal.RangeResultListener<K,V> listener)

Specified by:

loadEntriesBetween in interface OSBTreeBonsai<K,V>

flush

public void flush()

getRealBagSize

public int getRealBagSize(Map<K,OSBTreeRidBag.Change> changes)

Description copied from interface: OSBTreeBonsai

Hardcoded method for Bag to avoid creation of extra layer.

Don't make any changes to tree.

Specified by:

getRealBagSize in interface OSBTreeBonsai<K,V>

Parameters:

changes - Bag changes

Returns:

real bag size

getKeySerializer

public OBinarySerializer<K> getKeySerializer()

Specified by:

getKeySerializer in interface OSBTreeBonsai<K,V>

getValueSerializer

public OBinarySerializer<V> getValueSerializer()

Specified by:

getValueSerializer in interface OSBTreeBonsai<K,V>

debugPrintBucket

public void debugPrintBucket(PrintStream writer)
                      throws IOException

Throws:

IOException

debugPrintBucket

public void debugPrintBucket(OBonsaiBucketPointer bucketPointer,
                             PrintStream writer,
                             ArrayList<OBonsaiBucketPointer> path)
                      throws IOException

Throws:

IOException

startOperation

protected void startOperation()

Overrides:

startOperation in class ODurableComponent