com.orientechnologies.orient.core.storage.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.storage.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 (a.lomakin-at-orientdb.com), Artem Orobets

See Also:

OSBTree

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.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, 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(OAtomicOperation atomicOperation) Removes all entries from bonsai tree.
void	close()
void	close(boolean flush)
void	create(OAtomicOperation atomicOperation, OBinarySerializer<K> keySerializer, OBinarySerializer<V> valueSerializer)
void	debugPrintBucket(PrintStream writer)
void	delete(OAtomicOperation atomicOperation) Deletes a whole tree.
K	firstKey()
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,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)
void	markToDelete(OAtomicOperation atomicOperation)
boolean	put(OAtomicOperation atomicOperation, K key, V value)
V	remove(OAtomicOperation atomicOperation, K key)
long	size()
boolean	tryDelete(OAtomicOperation atomicOperation)

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

addFile, addPage, calculateInsideComponentOperation, deleteFile, executeInsideComponentOperation, getExtension, getFilledUpTo, getFullName, getLockName, getName, isFileExists, loadPageForRead, loadPageForRead, loadPageForWrite, openFile, pinPage, releasePageFromRead, releasePageFromWrite, setName, truncateFile, tryExecuteInsideComponentOperation

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

acquireExclusiveLock, 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(OAtomicOperation atomicOperation,
                   OBinarySerializer<K> keySerializer,
                   OBinarySerializer<V> valueSerializer)
            throws IOException

Throws:

IOException

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(OAtomicOperation atomicOperation,
                   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(OAtomicOperation atomicOperation)

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(OAtomicOperation atomicOperation)
            throws IOException

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

Specified by:

delete in interface OSBTreeBonsai<K,V>

Throws:

IOException

tryDelete

public boolean tryDelete(OAtomicOperation atomicOperation)

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(OAtomicOperation atomicOperation,
                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

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>

getRealBagSize

public int getRealBagSize(Map<K,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

markToDelete

public void markToDelete(OAtomicOperation atomicOperation)

Specified by:

markToDelete in interface OSBTreeBonsai<K,V>