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

Class OSBTreeBonsaiLocal<K,V>

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAbstract

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 OSBTreeV1 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:

• OSBTreeV1

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

Fields inherited from class com.orientechnologies.common.concur.resource.OSharedResourceAbstract

lock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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	create(OAtomicOperation atomicOperation, OBinarySerializer<K> keySerializer, OBinarySerializer<V> valueSerializer, int pageIndex, int pageOffset)
long	createComponent(OAtomicOperation atomicOperation)
void	debugPrintBucket(PrintStream writer)
void	delete(OAtomicOperation atomicOperation)	Deletes a whole tree.
void	deleteComponent(OAtomicOperation atomicOperation)
K	firstKey()
void	flush()
void	forEachItem(OBonsaiBucketPointer rootBucketPointer, Consumer<ORawPair<K,V>> consumer)
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)
boolean	isEmpty()
K	lastKey()
final void	load(OBinarySerializer<K> keySerializer, OBinarySerializer<V> valueSerializer)
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)
List<OBonsaiBucketPointer>	loadRoots()
void	markToDelete(OAtomicOperation atomicOperation)
boolean	put(OAtomicOperation atomicOperation, K key, V value)
V	remove(OAtomicOperation atomicOperation, K key)
long	size()

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, loadOrAddPageForWrite, loadPageForRead, loadPageForWrite, openFile, releasePageFromRead, releasePageFromWrite, setName, truncateFile, tryExecuteInsideComponentOperation

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

acquireExclusiveLock, acquireSharedLock, releaseExclusiveLock, releaseSharedLock

Methods inherited from class java.lang.Object

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

Constructor Details

OSBTreeBonsaiLocal

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

Method Details

createComponent

public long createComponent(OAtomicOperation atomicOperation)

create

public void create(OAtomicOperation atomicOperation,
 OBinarySerializer<K> keySerializer,
 OBinarySerializer<V> valueSerializer)
            throws IOException

Throws:

IOException

create

public void create(OAtomicOperation atomicOperation,
 OBinarySerializer<K> keySerializer,
 OBinarySerializer<V> valueSerializer,
 int pageIndex,
 int pageOffset)
            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>

loadRoots

public List<OBonsaiBucketPointer> loadRoots()
                                     throws IOException

Throws:

IOException

forEachItem

public void forEachItem(OBonsaiBucketPointer rootBucketPointer,
 Consumer<ORawPair<K,V>> consumer)
                 throws IOException

Throws:

IOException

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)

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

Specified by:

delete in interface OSBTreeBonsai<K,V>

deleteComponent

public void deleteComponent(OAtomicOperation atomicOperation)

load

public boolean load(OBonsaiBucketPointer rootBucketPointer)

load

public final void load(OBinarySerializer<K> keySerializer,
 OBinarySerializer<V> valueSerializer)
                throws IOException

Throws:

IOException

size

public long size()

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface OSBTreeBonsai<K,V>

Specified by:

isEmpty in interface OTreeInternal<K,V>

remove

public V remove(OAtomicOperation atomicOperation,
 K key)

Specified by:

remove in interface OSBTreeBonsai<K,V>

Specified by:

remove in interface OTreeInternal<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 OSBTreeBonsai<K,V>

Specified by:

loadEntriesMajor in interface OTreeInternal<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 OSBTreeBonsai<K,V>

Specified by:

firstKey in interface OTreeInternal<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,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)