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

Class OOfflineCluster

java.lang.Object

com.orientechnologies.orient.core.storage.cluster.OOfflineCluster

All Implemented Interfaces:

OCluster, OClusterInfo

public class OOfflineCluster
extends Object
implements OCluster

Represents an offline cluster, created with the "alter cluster X status offline" command. To restore the original cluster assure to have the cluster files in the right path and execute: "alter cluster X status online".

Since:

2.0

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

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

OCluster.ATTRIBUTES

Constructor Summary

Constructors

Constructor	Description
OOfflineCluster(OAbstractPaginatedStorage iStorage, int iId, String iName)

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 atomicOperation)	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 iId, String iClusterName)
void	configure(OStorage iStorage, OStorageClusterConfiguration iConfig)
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 atomicOperation, long clusterPosition)
String	encryption()
boolean	exists()
OPhysicalPosition[]	floorPositions(OPhysicalPosition position)
int	getBinaryVersion()
long	getEntries()
String	getFileName()
long	getFirstPosition()
int	getId()
long	getLastPosition()
String	getName()
long	getNextPosition()
OPhysicalPosition	getPhysicalPosition(OPhysicalPosition iPPosition)	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.
OPhysicalPosition[]	higherPositions(OPhysicalPosition position)
boolean	isDeleted(OPhysicalPosition iPPosition)	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)
ORawBuffer	readRecord(long clusterPosition)
ORawBuffer	readRecordIfVersionIsNotLatest(long clusterPosition, int recordVersion)
void	setClusterName(String name)
void	setEncryption(String encryptionName, String encryptionKey)
void	setRecordConflictStrategy(String conflictStrategy)
void	synch()
void	updateRecord(long clusterPosition, byte[] content, int recordVersion, byte recordType, OAtomicOperation atomicOperation)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

getRecordConflictStrategyName

Constructor Details

OOfflineCluster

public OOfflineCluster(OAbstractPaginatedStorage iStorage,
 int iId,
 String iName)

Method Details

configure

public void configure(int iId,
 String iClusterName)
               throws IOException

Specified by:

configure in interface OCluster

Throws:

IOException

configure

public void configure(OStorage iStorage,
 OStorageClusterConfiguration iConfig)
               throws IOException

Specified by:

configure in interface OCluster

Throws:

IOException

create

public void create(OAtomicOperation atomicOperation)
            throws IOException

Specified by:

create in interface OCluster

Throws:

IOException

open

public void open(OAtomicOperation atomicOperation)
          throws IOException

Specified by:

open in interface OCluster

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface OCluster

Throws:

IOException

close

public void close(boolean flush)
           throws IOException

Specified by:

close in interface OCluster

Throws:

IOException

delete

public void delete(OAtomicOperation atomicOperation)
            throws IOException

Specified by:

delete in interface OCluster

Throws:

IOException

setClusterName

public void setClusterName(String name)

Specified by:

setClusterName in interface OCluster

setRecordConflictStrategy

public void setRecordConflictStrategy(String conflictStrategy)

Specified by:

setRecordConflictStrategy in interface OCluster

setEncryption

public void setEncryption(String encryptionName,
 String encryptionKey)

Specified by:

setEncryption in interface OCluster

encryption

public String encryption()

Specified by:

encryption in interface OCluster

Specified by:

encryption in interface OClusterInfo

allocatePosition

public OPhysicalPosition allocatePosition(byte recordType,
 OAtomicOperation atomicOperation)
                                   throws IOException

Description copied from interface: OCluster

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

Specified by:

allocatePosition in interface OCluster

Parameters:

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

Returns:

the allocated position.

Throws:

IOException

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.

Specified by:

createRecord in interface OCluster

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.

deleteRecord

public boolean deleteRecord(OAtomicOperation atomicOperation,
 long clusterPosition)

Specified by:

deleteRecord in interface OCluster

updateRecord

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

Specified by:

updateRecord in interface OCluster

readRecord

public ORawBuffer readRecord(long clusterPosition)

Specified by:

readRecord in interface OCluster

readRecordIfVersionIsNotLatest

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

Specified by:

readRecordIfVersionIsNotLatest in interface OCluster

Throws:

IOException

ORecordNotFoundException

exists

public boolean exists()

Specified by:

exists in interface OCluster

getPhysicalPosition

public OPhysicalPosition getPhysicalPosition(OPhysicalPosition iPPosition)
                                      throws IOException

Description copied from interface: OCluster

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

Specified by:

getPhysicalPosition in interface OCluster

Throws:

IOException

getEntries

public long getEntries()

Specified by:

getEntries in interface OCluster

Specified by:

getEntries in interface OClusterInfo

getFirstPosition

public long getFirstPosition()
                      throws IOException

Specified by:

getFirstPosition in interface OCluster

Throws:

IOException

getLastPosition

public long getLastPosition()
                     throws IOException

Specified by:

getLastPosition in interface OCluster

Throws:

IOException

getNextPosition

public long getNextPosition()
                     throws IOException

Specified by:

getNextPosition in interface OCluster

Throws:

IOException

getFileName

public String getFileName()

Specified by:

getFileName in interface OCluster

Specified by:

getFileName in interface OClusterInfo

getId

public int getId()

Specified by:

getId in interface OCluster

Specified by:

getId in interface OClusterInfo

synch

public void synch()
           throws IOException

Specified by:

synch in interface OCluster

Throws:

IOException

getName

public String getName()

Specified by:

getName in interface OCluster

Specified by:

getName in interface OClusterInfo

getRecordsSize

public long getRecordsSize()
                    throws IOException

Description copied from interface: OCluster

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

Specified by:

getRecordsSize in interface OCluster

Throws:

IOException

compression

public String compression()

Specified by:

compression in interface OCluster

isSystemCluster

public boolean isSystemCluster()

Specified by:

isSystemCluster in interface OCluster

isDeleted

public boolean isDeleted(OPhysicalPosition iPPosition)
                  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.

Specified by:

isDeleted in interface OCluster

Throws:

IOException

higherPositions

public OPhysicalPosition[] higherPositions(OPhysicalPosition position)
                                    throws IOException

Specified by:

higherPositions in interface OCluster

Throws:

IOException

ceilingPositions

public OPhysicalPosition[] ceilingPositions(OPhysicalPosition position)
                                     throws IOException

Specified by:

ceilingPositions in interface OCluster

Throws:

IOException

lowerPositions

public OPhysicalPosition[] lowerPositions(OPhysicalPosition position)
                                   throws IOException

Specified by:

lowerPositions in interface OCluster

Throws:

IOException

floorPositions

public OPhysicalPosition[] floorPositions(OPhysicalPosition position)
                                   throws IOException

Specified by:

floorPositions in interface OCluster

Throws:

IOException

getRecordConflictStrategy

public ORecordConflictStrategy getRecordConflictStrategy()

Specified by:

getRecordConflictStrategy in interface OCluster

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.

Specified by:

acquireAtomicExclusiveLock in interface OCluster

nextPage

public OClusterBrowsePage nextPage(long lastPosition)

Specified by:

nextPage in interface OCluster

getBinaryVersion

public int getBinaryVersion()

Specified by:

getBinaryVersion in interface OCluster