com.orientechnologies.orient.core.storage.index.hashindex.local

Class OHashIndexBucket<K,V>

java.lang.Object

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

com.orientechnologies.orient.core.storage.index.hashindex.local.OHashIndexBucket<K,V>

All Implemented Interfaces:

Iterable<OHashIndexBucket.Entry<K,V>>

public class OHashIndexBucket<K,V>
extends ODurablePage
implements Iterable<OHashIndexBucket.Entry<K,V>>

Since:

2/17/13

Author:

Andrey Lomakin (a.lomakin-at-orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OHashIndexBucket.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_BUCKET_SIZE_BYTES

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

CRC32_OFFSET, MAGIC_NUMBER_OFFSET, MAX_PAGE_SIZE_BYTES, NEXT_FREE_POSITION, WAL_POSITION_OFFSET, WAL_SEGMENT_OFFSET

Constructor Summary

Constructors

Constructor and Description
OHashIndexBucket(int depth, OCacheEntry cacheEntry, OBinarySerializer<K> keySerializer, OBinarySerializer<V> valueSerializer, OType[] keyTypes, OEncryption encryption)
OHashIndexBucket(OCacheEntry cacheEntry, OBinarySerializer<K> keySerializer, OBinarySerializer<V> valueSerializer, OType[] keyTypes, OEncryption encryption)

Method Summary

Modifier and Type	Method and Description
boolean	addEntry(long hashCode, K key, V value)
void	appendEntry(long hashCode, K key, V value)
OHashIndexBucket.Entry<K,V>	deleteEntry(int index)
OHashIndexBucket.Entry<K,V>	find(K key, long hashCode)
int	getContentSize()
int	getDepth()
OHashIndexBucket.Entry<K,V>	getEntry(int index)
long	getHashCode(int index)
int	getIndex(long hashCode, K key)
K	getKey(int index)
long	getNextRemovedBucketPair()
long	getSplitHistory(int level)
V	getValue(int index) Obtains the value stored under the given index in this bucket.
void	init(int depth)
Iterator<OHashIndexBucket.Entry<K,V>>	iterator()
Iterator<OHashIndexBucket.Entry<K,V>>	iterator(int index)
int	mergedSize(OHashIndexBucket buddyBucket)
void	setDepth(int depth)
void	setNextRemovedBucketPair(long nextRemovedBucketPair)
void	setSplitHistory(int level, long position)
int	size()
int	updateEntry(int index, V value)

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

deserializeFromDirectMemory, getBinaryValue, getByteValue, getChanges, getIntValue, getLogSequenceNumber, getLogSequenceNumberFromPage, getLongValue, getLsn, getObjectSizeInDirectMemory, getPageData, getShortValue, moveData, restoreChanges, setBinaryValue, setByteValue, setIntValue, setLongValue, setLsn, setShortValue, 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

Field Detail

MAX_BUCKET_SIZE_BYTES

public static final int MAX_BUCKET_SIZE_BYTES

Constructor Detail

OHashIndexBucket

public OHashIndexBucket(int depth,
                        OCacheEntry cacheEntry,
                        OBinarySerializer<K> keySerializer,
                        OBinarySerializer<V> valueSerializer,
                        OType[] keyTypes,
                        OEncryption encryption)
                 throws IOException

Throws:

IOException

OHashIndexBucket

public OHashIndexBucket(OCacheEntry cacheEntry,
                        OBinarySerializer<K> keySerializer,
                        OBinarySerializer<V> valueSerializer,
                        OType[] keyTypes,
                        OEncryption encryption)

Method Detail

init

public void init(int depth)
          throws IOException

Throws:

IOException

find

public OHashIndexBucket.Entry<K,V> find(K key,
                                        long hashCode)

getEntry

public OHashIndexBucket.Entry<K,V> getEntry(int index)

getValue

public V getValue(int index)

Obtains the value stored under the given index in this bucket.

Parameters:

index - the value index.

Returns:

the obtained value.

getHashCode

public long getHashCode(int index)

getKey

public K getKey(int index)

getIndex

public int getIndex(long hashCode,
                    K key)

size

public int size()

iterator

public Iterator<OHashIndexBucket.Entry<K,V>> iterator()

Specified by:

iterator in interface Iterable<OHashIndexBucket.Entry<K,V>>

iterator

public Iterator<OHashIndexBucket.Entry<K,V>> iterator(int index)

mergedSize

public int mergedSize(OHashIndexBucket buddyBucket)

getContentSize

public int getContentSize()

updateEntry

public int updateEntry(int index,
                       V value)
                throws IOException

Throws:

IOException

deleteEntry

public OHashIndexBucket.Entry<K,V> deleteEntry(int index)
                                        throws IOException

Throws:

IOException

addEntry

public boolean addEntry(long hashCode,
                        K key,
                        V value)
                 throws IOException

Throws:

IOException

appendEntry

public void appendEntry(long hashCode,
                        K key,
                        V value)
                 throws IOException

Throws:

IOException

getDepth

public int getDepth()

setDepth

public void setDepth(int depth)

getNextRemovedBucketPair

public long getNextRemovedBucketPair()

setNextRemovedBucketPair

public void setNextRemovedBucketPair(long nextRemovedBucketPair)
                              throws IOException

Throws:

IOException

getSplitHistory

public long getSplitHistory(int level)

setSplitHistory

public void setSplitHistory(int level,
                            long position)
                     throws IOException

Throws:

IOException