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

Class OClusterPositionMap

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAdaptive

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

com.orientechnologies.orient.core.storage.impl.local.paginated.OClusterPositionMap

public class OClusterPositionMap
extends ODurableComponent

Since:

10/7/13

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEF_EXTENSION

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
OClusterPositionMap(OAbstractPaginatedStorage storage, String name, String lockName)

Method Summary

Modifier and Type	Method and Description
long	add(long pageIndex, int recordPosition)
long	allocate()
long[]	ceilingPositions(long clusterPosition)
void	close(boolean flush)
void	create()
void	delete()
long[]	floorPositions(long clusterPosition)
void	flush()
OClusterPositionMapBucket.PositionEntry	get(long clusterPosition, int pageCount)
long	getFileId()
long	getFirstPosition()
long	getLastPosition()
long	getNextPosition() Returns the next position available.
byte	getStatus(long clusterPosition)
long[]	higherPositions(long clusterPosition)
long[]	lowerPositions(long clusterPosition)
void	open()
OClusterPositionMapBucket.PositionEntry	remove(long clusterPosition)
void	rename(String newName)
void	replaceFileId(long newFileId)
void	resurrect(long clusterPosition)
void	truncate()
void	update(long clusterPosition, OClusterPositionMapBucket.PositionEntry entry)

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, startOperation, 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

Field Detail

DEF_EXTENSION

public static final String DEF_EXTENSION

See Also:

Constant Field Values

Constructor Detail

OClusterPositionMap

public OClusterPositionMap(OAbstractPaginatedStorage storage,
                           String name,
                           String lockName)

Method Detail

open

public void open()
          throws IOException

Throws:

IOException

create

public void create()
            throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

close

public void close(boolean flush)
           throws IOException

Throws:

IOException

truncate

public void truncate()
              throws IOException

Throws:

IOException

delete

public void delete()
            throws IOException

Throws:

IOException

rename

public void rename(String newName)
            throws IOException

Throws:

IOException

add

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

Throws:

IOException

allocate

public long allocate()
              throws IOException

Throws:

IOException

update

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

Throws:

IOException

resurrect

public void resurrect(long clusterPosition)
               throws IOException

Throws:

IOException

get

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

Throws:

IOException

remove

public OClusterPositionMapBucket.PositionEntry remove(long clusterPosition)
                                               throws IOException

Throws:

IOException

higherPositions

public long[] higherPositions(long clusterPosition)
                       throws IOException

Throws:

IOException

ceilingPositions

public long[] ceilingPositions(long clusterPosition)
                        throws IOException

Throws:

IOException

lowerPositions

public long[] lowerPositions(long clusterPosition)
                      throws IOException

Throws:

IOException

floorPositions

public long[] floorPositions(long clusterPosition)
                      throws IOException

Throws:

IOException

getFirstPosition

public long getFirstPosition()
                      throws IOException

Throws:

IOException

getStatus

public byte getStatus(long clusterPosition)
               throws IOException

Throws:

IOException

getLastPosition

public long getLastPosition()
                     throws IOException

Throws:

IOException

getNextPosition

public long getNextPosition()
                     throws IOException

Returns the next position available.

Throws:

IOException

getFileId

public long getFileId()

replaceFileId

public void replaceFileId(long newFileId)