com.orientechnologies.orient.core.storage.cluster.v1

Class OPaginatedClusterV1

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.OPaginatedCluster

com.orientechnologies.orient.core.storage.cluster.v1.OPaginatedClusterV1

All Implemented Interfaces:

OCluster

public final class OPaginatedClusterV1
extends OPaginatedCluster

Since:

10/7/13

Author:

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

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.storage.cluster.OPaginatedCluster

OPaginatedCluster.RECORD_STATUS

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.OCluster

OCluster.ATTRIBUTES

Field Summary

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

DEF_EXTENSION

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

atomicOperationsManager, readCache, storage, writeCache

Constructor Summary

Constructors

Constructor and Description
OPaginatedClusterV1(String name, OAbstractPaginatedStorage storage)
OPaginatedClusterV1(String name, String dataExtension, String cpmExtension, OAbstractPaginatedStorage storage)

Method Summary

Modifier and Type	Method and Description
void	acquireAtomicExclusiveLock() Acquires exclusive lock in the active atomic operation running on the current thread for this cluster.
OPhysicalPosition	allocatePosition(OAtomicOperation atomicOperation, byte recordType) Allocates a physical position pointer on the storage for generate an id without a content.
OPhysicalPosition[]	ceilingPositions(OPhysicalPosition position)
void	close(boolean flush)
String	compression()
void	configure(OStorage storage, int id, String clusterName, Object... parameters)
void	configure(OStorage storage, OStorageClusterConfiguration config)
void	create(OAtomicOperation atomicOperation, int startSize)
OPhysicalPosition	createRecord(OAtomicOperation atomicOperation, byte[] content, int recordVersion, byte recordType, OPhysicalPosition allocatedPosition) Creates a new record in the cluster.
void	delete(OAtomicOperation atomicOperation)
boolean	deleteRecord(OAtomicOperation atomicOperation, long clusterPosition)
String	encryption()
OPhysicalPosition[]	floorPositions(OPhysicalPosition position)
int	getBinaryVersion()
long	getEntries()
long	getFileId() Returns the fileId used in disk cache.
String	getFileName()
long	getFirstPosition()
int	getId()
long	getLastPosition()
long	getNextPosition()
OPhysicalPosition	getPhysicalPosition(OPhysicalPosition position) Fills and return the PhysicalPosition object received as parameter with the physical position of logical record iPosition
ORecordConflictStrategy	getRecordConflictStrategy()
long	getRecordsSize() Returns the size of the records contained in the cluster in bytes.
OPaginatedCluster.RECORD_STATUS	getRecordStatus(long clusterPosition)
long	getTombstonesCount()
boolean	hideRecord(OAtomicOperation atomicOperation, long position) Hides records content by putting tombstone on the records position but does not delete record itself.
OPhysicalPosition[]	higherPositions(OPhysicalPosition position)
boolean	isDeleted(OPhysicalPosition position) Check if a rid is existent and deleted or not existent return true only if delete flag is set.
boolean	isSystemCluster()
OPhysicalPosition[]	lowerPositions(OPhysicalPosition position)
OClusterBrowsePage	nextPage(long lastPosition)
void	open()
OPaginatedClusterDebug	readDebug(long clusterPosition)
ORawBuffer	readRecord(long clusterPosition, boolean prefetchRecords)
ORawBuffer	readRecordIfVersionIsNotLatest(long clusterPosition, int recordVersion)
float	recordGrowFactor()
float	recordOverflowGrowFactor()
void	recycleRecord(OAtomicOperation atomicOperation, long clusterPosition, byte[] content, int recordVersion, byte recordType) Recycles a deleted record.
void	registerInStorageConfig(OAtomicOperation atomicOperation, OClusterBasedStorageConfiguration root)
Object	set(OAtomicOperation atomicOperation, OCluster.ATTRIBUTES attribute, Object value)
void	synch()
String	toString()
void	truncate(OAtomicOperation atomicOperation) Truncates the cluster content.
void	updateRecord(OAtomicOperation atomicOperation, long clusterPosition, byte[] content, int recordVersion, byte recordType)

Methods inherited from class com.orientechnologies.orient.core.storage.cluster.OPaginatedCluster

getLatestBinaryVersion

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

Methods inherited from interface com.orientechnologies.orient.core.storage.OCluster

getName

Constructor Detail

OPaginatedClusterV1

public OPaginatedClusterV1(String name,
                           OAbstractPaginatedStorage storage)

OPaginatedClusterV1

public OPaginatedClusterV1(String name,
                           String dataExtension,
                           String cpmExtension,
                           OAbstractPaginatedStorage storage)

Method Detail

configure

public void configure(OStorage storage,
                      int id,
                      String clusterName,
                      Object... parameters)
               throws IOException

Throws:

IOException

getBinaryVersion

public int getBinaryVersion()

configure

public void configure(OStorage storage,
                      OStorageClusterConfiguration config)
               throws IOException

Throws:

IOException

create

public void create(OAtomicOperation atomicOperation,
                   int startSize)

registerInStorageConfig

public void registerInStorageConfig(OAtomicOperation atomicOperation,
                                    OClusterBasedStorageConfiguration root)

Specified by:

registerInStorageConfig in class OPaginatedCluster

open

public void open()
          throws IOException

Throws:

IOException

close

public void close(boolean flush)

delete

public void delete(OAtomicOperation atomicOperation)

set

public Object set(OAtomicOperation atomicOperation,
                  OCluster.ATTRIBUTES attribute,
                  Object value)
           throws IOException

Throws:

IOException

isSystemCluster

public boolean isSystemCluster()

recordGrowFactor

public float recordGrowFactor()

recordOverflowGrowFactor

public float recordOverflowGrowFactor()

compression

public String compression()

encryption

public String encryption()

allocatePosition

public OPhysicalPosition allocatePosition(OAtomicOperation atomicOperation,
                                          byte recordType)

Description copied from interface: OCluster

Allocates a physical position pointer on the storage for generate an id without a content.

recordType - the type of record of which allocate the position.

Returns:

the allocated position.

createRecord

public OPhysicalPosition createRecord(OAtomicOperation atomicOperation,
                                      byte[] content,
                                      int recordVersion,
                                      byte recordType,
                                      OPhysicalPosition allocatedPosition)

Description copied from interface: OCluster

Creates a new record in the cluster.

content - the content of the record.

recordVersion - the current version

recordType - the type of the record

allocatedPosition - the eventual allocated position or null if there is no allocated position.

Returns:

the position where the record si created.

readRecord

public ORawBuffer readRecord(long clusterPosition,
                             boolean prefetchRecords)
                      throws IOException

Throws:

IOException

readRecordIfVersionIsNotLatest

public ORawBuffer readRecordIfVersionIsNotLatest(long clusterPosition,
                                                 int recordVersion)
                                          throws IOException,
                                                 ORecordNotFoundException

Throws:

IOException

ORecordNotFoundException

deleteRecord

public boolean deleteRecord(OAtomicOperation atomicOperation,
                            long clusterPosition)

hideRecord

public boolean hideRecord(OAtomicOperation atomicOperation,
                          long position)

Description copied from interface: OCluster

Hides records content by putting tombstone on the records position but does not delete record itself.

This method is used in case of record content itself is broken and cannot be read or deleted. So it is emergence method.

position - Position of record in cluster

Returns:

false if record does not exist.

updateRecord

public void updateRecord(OAtomicOperation atomicOperation,
                         long clusterPosition,
                         byte[] content,
                         int recordVersion,
                         byte recordType)

recycleRecord

public void recycleRecord(OAtomicOperation atomicOperation,
                          long clusterPosition,
                          byte[] content,
                          int recordVersion,
                          byte recordType)

Recycles a deleted record.

getTombstonesCount

public long getTombstonesCount()

truncate

public void truncate(OAtomicOperation atomicOperation)

Description copied from interface: OCluster

Truncates the cluster content. All the entries will be removed.

getPhysicalPosition

public OPhysicalPosition getPhysicalPosition(OPhysicalPosition position)
                                      throws IOException

Description copied from interface: OCluster

Fills and return the PhysicalPosition object received as parameter with the physical position of logical record iPosition

Throws:

IOException

isDeleted

public boolean isDeleted(OPhysicalPosition position)
                  throws IOException

Description copied from interface: OCluster

Check if a rid is existent and deleted or not existent return true only if delete flag is set.

Throws:

IOException

getEntries

public long getEntries()

getFirstPosition

public long getFirstPosition()
                      throws IOException

Throws:

IOException

getLastPosition

public long getLastPosition()
                     throws IOException

Throws:

IOException

getNextPosition

public long getNextPosition()
                     throws IOException

Throws:

IOException

getFileName

public String getFileName()

getId

public int getId()

getFileId

public long getFileId()

Returns the fileId used in disk cache.

Specified by:

getFileId in class OPaginatedCluster

synch

public void synch()

getRecordsSize

public long getRecordsSize()
                    throws IOException

Description copied from interface: OCluster

Returns the size of the records contained in the cluster in bytes.

Throws:

IOException

higherPositions

public OPhysicalPosition[] higherPositions(OPhysicalPosition position)
                                    throws IOException

Throws:

IOException

ceilingPositions

public OPhysicalPosition[] ceilingPositions(OPhysicalPosition position)
                                     throws IOException

Throws:

IOException

lowerPositions

public OPhysicalPosition[] lowerPositions(OPhysicalPosition position)
                                   throws IOException

Throws:

IOException

floorPositions

public OPhysicalPosition[] floorPositions(OPhysicalPosition position)
                                   throws IOException

Throws:

IOException

getRecordConflictStrategy

public ORecordConflictStrategy getRecordConflictStrategy()

readDebug

public OPaginatedClusterDebug readDebug(long clusterPosition)
                                 throws IOException

Specified by:

readDebug in class OPaginatedCluster

Throws:

IOException

getRecordStatus

public OPaginatedCluster.RECORD_STATUS getRecordStatus(long clusterPosition)
                                                throws IOException

Specified by:

getRecordStatus in class OPaginatedCluster

Throws:

IOException

acquireAtomicExclusiveLock

public void acquireAtomicExclusiveLock()

Description copied from interface: OCluster

Acquires exclusive lock in the active atomic operation running on the current thread for this cluster.

toString

public String toString()

Overrides:

toString in class Object

nextPage

public OClusterBrowsePage nextPage(long lastPosition)
                            throws IOException

Throws:

IOException