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

Class OPaginatedClusterV1

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAbstract

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

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

lock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	acquireAtomicExclusiveLock()	Acquires exclusive lock in the active atomic operation running on the current thread for this cluster.
OPhysicalPosition	allocatePosition(byte recordType, OAtomicOperation operation)	Allocates a physical position pointer on the storage for generate an id without a content.
OPhysicalPosition[]	ceilingPositions(OPhysicalPosition position)
void	close()
void	close(boolean flush)
String	compression()
void	configure(int id, String clusterName)
void	configure(OStorage storage, OStorageClusterConfiguration config)
void	create(OAtomicOperation atomicOperation)
OPhysicalPosition	createRecord(byte[] content, int recordVersion, byte recordType, OPhysicalPosition allocatedPosition, OAtomicOperation atomicOperation)	Creates a new record in the cluster.
void	delete(OAtomicOperation atomicOperation)
boolean	deleteRecord(OAtomicOperation operation, long clusterPosition)
String	encryption()
boolean	exists()
OPhysicalPosition[]	floorPositions(OPhysicalPosition position)
OStoragePaginatedClusterConfiguration	generateClusterConfig()
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()
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(OAtomicOperation atomicOperation)
OPaginatedClusterDebug	readDebug(long clusterPosition)
ORawBuffer	readRecord(long clusterPosition, boolean prefetchRecords)
ORawBuffer	readRecordIfVersionIsNotLatest(long clusterPosition, int recordVersion)
void	setClusterName(String newName)
void	setEncryption(String method, String key)
void	setRecordConflictStrategy(String stringValue)
void	synch()
String	toString()
void	updateRecord(long clusterPosition, byte[] content, int recordVersion, byte recordType, OAtomicOperation atomicOperation)

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

getLatestBinaryVersion, replaceClusterMapFile, replaceFile

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

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

getName

Constructor Details

OPaginatedClusterV1

public OPaginatedClusterV1(String name,
 OAbstractPaginatedStorage storage)

OPaginatedClusterV1

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

Method Details

configure

public void configure(int id,
 String clusterName)
               throws IOException

Throws:

IOException

exists

public boolean exists()

getBinaryVersion

public int getBinaryVersion()

generateClusterConfig

public OStoragePaginatedClusterConfiguration generateClusterConfig()

Specified by:

generateClusterConfig in class OPaginatedCluster

configure

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

Throws:

IOException

create

public void create(OAtomicOperation atomicOperation)

open

public void open(OAtomicOperation atomicOperation)
          throws IOException

Throws:

IOException

close

public void close()

close

public void close(boolean flush)

delete

public void delete(OAtomicOperation atomicOperation)

isSystemCluster

public boolean isSystemCluster()

compression

public String compression()

encryption

public String encryption()

allocatePosition

public OPhysicalPosition allocatePosition(byte recordType,
 OAtomicOperation operation)

Description copied from interface: OCluster

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

Parameters:

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

Returns:

the allocated position.

createRecord

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

Description copied from interface: OCluster

Creates a new record in the cluster.

Parameters:

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 operation,
 long clusterPosition)

updateRecord

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

getTombstonesCount

public long getTombstonesCount()

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()

setRecordConflictStrategy

public void setRecordConflictStrategy(String stringValue)

setEncryption

public void setEncryption(String method,
 String key)

setClusterName

public void setClusterName(String newName)

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