com.orientechnologies.orient.core.storage.cluster.v2

Class OClusterPositionMapV2

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAdaptive

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

com.orientechnologies.orient.core.storage.cluster.OClusterPositionMap

com.orientechnologies.orient.core.storage.cluster.v2.OClusterPositionMapV2

public final class OClusterPositionMapV2
extends OClusterPositionMap

Since:

10/7/13

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OClusterPositionMapV2.OClusterPositionEntry

Field Summary

Fields inherited from class com.orientechnologies.orient.core.storage.cluster.OClusterPositionMap

DEF_EXTENSION

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

atomicOperationsManager, readCache, storage, writeCache

Method Summary

Modifier and Type	Method and Description
long	add(long pageIndex, int recordPosition, OAtomicOperation atomicOperation)
long	allocate(OAtomicOperation atomicOperation)
void	close(boolean flush)
void	create(OAtomicOperation atomicOperation)
void	delete(OAtomicOperation atomicOperation)
void	flush()
OClusterPositionMapBucket.PositionEntry	get(long clusterPosition, int pageCount, OAtomicOperation atomicOperation)
long	getFileId()
long	getLastPosition(OAtomicOperation atomicOperation)
byte	getStatus(long clusterPosition, OAtomicOperation atomicOperation)
void	open(OAtomicOperation atomicOperation)
void	remove(long clusterPosition, OAtomicOperation atomicOperation)
void	truncate(OAtomicOperation atomicOperation)
void	update(long clusterPosition, OClusterPositionMapBucket.PositionEntry entry, 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, 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

Method Detail

open

public void open(OAtomicOperation atomicOperation)
          throws IOException

Throws:

IOException

create

public void create(OAtomicOperation atomicOperation)
            throws IOException

Throws:

IOException

flush

public void flush()

close

public void close(boolean flush)

truncate

public void truncate(OAtomicOperation atomicOperation)
              throws IOException

Throws:

IOException

delete

public void delete(OAtomicOperation atomicOperation)
            throws IOException

Throws:

IOException

add

public long add(long pageIndex,
                int recordPosition,
                OAtomicOperation atomicOperation)
         throws IOException

Throws:

IOException

allocate

public long allocate(OAtomicOperation atomicOperation)
              throws IOException

Throws:

IOException

update

public void update(long clusterPosition,
                   OClusterPositionMapBucket.PositionEntry entry,
                   OAtomicOperation atomicOperation)
            throws IOException

Throws:

IOException

get

public OClusterPositionMapBucket.PositionEntry get(long clusterPosition,
                                                   int pageCount,
                                                   OAtomicOperation atomicOperation)
                                            throws IOException

Throws:

IOException

remove

public void remove(long clusterPosition,
                   OAtomicOperation atomicOperation)
            throws IOException

Throws:

IOException

getStatus

public byte getStatus(long clusterPosition,
                      OAtomicOperation atomicOperation)
               throws IOException

Throws:

IOException

getLastPosition

public long getLastPosition(OAtomicOperation atomicOperation)
                     throws IOException

Throws:

IOException

getFileId

public long getFileId()