com.orientechnologies.orient.server.distributed.impl

Class ODistributedStorage

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedStorage

All Implemented Interfaces:

OSharedContainer, OFreezableStorageComponent, OAutoshardedStorage, OStorage, OBackupable

public class ODistributedStorage
extends Object
implements OStorage, OFreezableStorageComponent, OAutoshardedStorage

Distributed storage implementation that routes to the owner node the request.

Author:

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

Nested Class Summary

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

OStorage.LOCKING_STRATEGY, OStorage.STATUS

Field Summary

Fields inherited from interface com.orientechnologies.orient.core.storage.OStorage

CLUSTER_DEFAULT_NAME

Constructor Summary

Constructors

Constructor and Description
ODistributedStorage(OServer iServer, String dbName)

Method Summary

Modifier and Type	Method and Description
void	acquireDistributedExclusiveLock(long timeout)
protected ODistributedRequestId	acquireRecordLock(ORecordId rid)
int	addCluster(String iClusterName, int iRequestedId, Object... iParameters) Add a new cluster into the storage.
int	addCluster(String iClusterName, Object... iParameters) Add a new cluster into the storage.
protected void	asynchronousExecution(OAsynchDistributedOperation iOperation)
List<String>	backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize) Executes a backup of the database.
OPhysicalPosition[]	ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)
protected String	checkForCluster(ORecord record, String localNodeName, ODistributedConfiguration dbCfg)
boolean	checkForRecordValidity(OPhysicalPosition ppos)
protected void	checkNodeIsMaster(String localNodeName, ODistributedConfiguration dbCfg, String operation)
protected void	checkWriteQuorum(ODistributedConfiguration dbCfg, String clusterName, String localNodeName)
boolean	cleanOutRecord(ORecordId recordId, int recordVersion, int iMode, ORecordCallback<Boolean> callback)
void	clearLastValidBackup()
void	clearProperties()
void	close()
void	close(boolean iForce, boolean onDelete)
void	closeOnDrop()
Object	command(OCommandRequestText iCommand) Execute the command request and return the result back.
List<ORecordOperation>	commit(OTransactionInternal iTx)
long	count(int iClusterId)
long	count(int[] iClusterIds)
long	count(int[] iClusterIds, boolean countTombstones)
long	count(int iClusterId, boolean countTombstones)
long	countRecords() Returns the total number of records.
void	create(OContextConfiguration iProperties)
OStorageOperationResult<OPhysicalPosition>	createRecord(ORecordId iRecordId, byte[] iContent, int iRecordVersion, byte iRecordType, int iMode, ORecordCallback<Long> iCallback)
void	delete()
OStorageOperationResult<Boolean>	deleteRecord(ORecordId iRecordId, int iVersion, int iMode, ORecordCallback<Boolean> iCallback)
boolean	dropCluster(int iId, boolean iTruncate) Drops a cluster.
boolean	dropCluster(String iClusterName, boolean iTruncate)
protected void	dropStorageFiles()
static void	dropStorageFiles(OAbstractPaginatedStorage wrapped)
protected Object	executeCommand(OCommandRequestText iCommand, String localNodeName, Collection<String> involvedClusters, OAbstractCommandTask task, Set<String> nodes, boolean executedLocally)
protected boolean	executeOnlyLocally(String localNodeName, ODistributedConfiguration dbCfg, OCommandExecutor exec, Collection<String> involvedClusters, Collection<String> nodes) Only idempotent commands that don't involve any other node can be executed locally.
protected Map<String,Object>	executeOnServers(OCommandRequestText iCommand, OCommandExecutor exec, Collection<String> involvedClusters, Map<String,Collection<String>> nodeClusterMap)
boolean	exists()
boolean	existsResource(String iName)
OPhysicalPosition[]	floorPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)
void	freeze(boolean throwException) After this method finished it's execution, all threads that are going to perform data modifications in storage should wait till OFreezableStorageComponent.release() method will be called.
void	fullIncrementalBackup(OutputStream stream)
protected OAsyncReplicationError	getAsyncReplicationError()
long[]	getClusterDataRange(int currentClusterId) Returns a pair of long values telling the begin and end positions of data in the requested cluster.
String	getClusterEncryption(int clusterId)
int	getClusterIdByName(String iClusterName)
String	getClusterNameById(int clusterId)
String	getClusterNameByRID(ORecordId iRid)
Set<String>	getClusterNames()
long	getClusterNextPosition(int clusterId)
ORecordConflictStrategy	getClusterRecordConflictStrategy()
String	getClusterRecordConflictStrategy(int clusterId)
long	getClusterRecordsSizeById(int clusterId)
long	getClusterRecordsSizeByName(String clusterName)
int	getClusters()
OCurrentStorageComponentsFactory	getComponentsFactory()
OStorageConfiguration	getConfiguration()
int	getConfigurationUpdated()
String	getCreatedAtVersion() Supported only in embedded storage.
int	getDefaultClusterId()
protected File	getDistributedConfigFile()
ODistributedConfiguration	getDistributedConfiguration()
ODistributedServerManager	getDistributedManager()
ODistributedStorageEventListener	getEventListener()
long	getLastClusterPosition(int clusterId)
OSyncSource	getLastValidBackup()
ODistributedDatabase	getLocalDistributedDatabase()
String	getName()
String	getNodeId()
String	getPhysicalClusterNameById(int iClusterId)
ORecordMetadata	getRecordMetadata(ORID rid)
OPaginatedCluster.RECORD_STATUS	getRecordStatus(ORID rid)
<T> T	getResource(String iName, Callable<T> iCallback)
OSBTreeCollectionManager	getSBtreeCollectionManager()
OServer	getServer()
long	getSize() Returns the size of the database.
OStorage.STATUS	getStatus() Returns the current storage's status
String	getStorageId() Storage unique id, made by node name + database name
String	getType() Returns the storage's type.
OStorage	getUnderlying()
String	getURL()
long	getVersion()
protected void	handleDistributedException(String iMessage, Exception e, Object... iParams)
OStorageOperationResult<Boolean>	hideRecord(ORecordId recordId, int mode, ORecordCallback<Boolean> callback)
OPhysicalPosition[]	higherPhysicalPositions(int currentClusterId, OPhysicalPosition entry)
String	incrementalBackup(String backupDirectory, OCallable<Void,Void> started)
boolean	isAssigningClusterIds()
boolean	isClosed()
boolean	isDistributed()
boolean	isLocalEnv() Check if the distributed need to run only as local env
boolean	isRemote()
boolean	isSystemCluster(int clusterId)
ODocument	loadDatabaseConfiguration(File file)
OPhysicalPosition[]	lowerPhysicalPositions(int currentClusterId, OPhysicalPosition entry)
protected Object	mergeResultByAggregation(OCommandExecutorSQLSelect select, Map<String,Object> iResults)
void	open(String iUserName, String iUserPassword, OContextConfiguration iProperties)
OStorageOperationResult<ORawBuffer>	readRecord(ORecordId iRecordId, String iFetchPlan, boolean iIgnoreCache, boolean prefetchRecords, ORecordCallback<ORawBuffer> iCallback)
OStorageOperationResult<ORawBuffer>	readRecordIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion)
OStorageOperationResult<Integer>	recyclePosition(ORecordId iRecordId, byte[] iContent, int iVersion, byte iRecordType) Resurrects a record that was previously deleted, with a new content.
void	release() After this method finished execution all threads that are waiting to perform data modifications in storage will be awaken and will be allowed to continue their execution.
void	releaseDistributedExclusiveLock()
protected void	releaseRecordLock(ORecordId rid, ODistributedRequestId requestId)
void	reload()
void	removeProperty(String property)
<T> T	removeResource(String iName)
void	replaceIfNeeded(OAbstractPaginatedStorage wrapped)
void	resetLastValidBackup()
void	restore(InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener) Executes a restore of a database backup.
void	restoreFromIncrementalBackup(String filePath)
void	restoreFullIncrementalBackup(InputStream stream)
void	rollback(OTransactionInternal iTx)
protected void	saveDatabaseConfiguration()
void	setCharset(String charset)
void	setClusterAttribute(int clusterId, OCluster.ATTRIBUTES attribute, Object value)
Object	setClusterAttribute(String clusterName, OCluster.ATTRIBUTES attribute, Object value)
void	setClusterSelection(String clusterSelection)
void	setConflictStrategy(ORecordConflictStrategy iResolver)
void	setDateFormat(String dateFormat)
void	setDateTimeFormat(String dateTimeFormat)
void	setDefaultClusterId(int defaultClusterId)
void	setDistributedConfiguration(OModifiableDistributedConfiguration distributedConfiguration)
void	setEventListener(ODistributedStorageEventListener eventListener)
void	setIndexMgrRecordId(String indexMgrRecordId)
void	setLastValidBackup(OSyncSource lastValidBackup)
void	setLocaleCountry(String localeCountry)
void	setLocaleLanguage(String locale)
void	setMinimumClusters(int minimumClusters)
void	setProperty(String property, String value)
void	setRecordSerializer(String recordSerializer, int version)
void	setSchemaRecordId(String schemaRecordId)
void	setTimeZone(TimeZone timeZoneValue)
void	setValidation(boolean validation)
void	shutdown() This method is called in Orient.shutdown() method.
void	shutdownAsynchronousWorker()
void	startAsynchronousWorker()
boolean	supportIncremental()
void	synch()
void	truncateCluster(String clusterName)
protected void	undoCommandOnLocalServer(OCommandRequestText iCommand)
void	wrap(OAbstractPaginatedStorage wrapped)

Methods inherited from class java.lang.Object

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

Constructor Detail

ODistributedStorage

public ODistributedStorage(OServer iServer,
                           String dbName)

Method Detail

replaceIfNeeded

public void replaceIfNeeded(OAbstractPaginatedStorage wrapped)

wrap

public void wrap(OAbstractPaginatedStorage wrapped)

getCreatedAtVersion

public String getCreatedAtVersion()

Supported only in embedded storage. Use SELECT FROM metadata:storage instead.

Specified by:

getCreatedAtVersion in interface OStorage

Returns:

Version of product release under which storage was created.

startAsynchronousWorker

public void startAsynchronousWorker()

isDistributed

public boolean isDistributed()

Specified by:

isDistributed in interface OStorage

isAssigningClusterIds

public boolean isAssigningClusterIds()

Specified by:

isAssigningClusterIds in interface OStorage

command

public Object command(OCommandRequestText iCommand)

Description copied from interface: OStorage

Execute the command request and return the result back.

Specified by:

command in interface OStorage

acquireDistributedExclusiveLock

public void acquireDistributedExclusiveLock(long timeout)

Specified by:

acquireDistributedExclusiveLock in interface OAutoshardedStorage

releaseDistributedExclusiveLock

public void releaseDistributedExclusiveLock()

Specified by:

releaseDistributedExclusiveLock in interface OAutoshardedStorage

executeCommand

protected Object executeCommand(OCommandRequestText iCommand,
                                String localNodeName,
                                Collection<String> involvedClusters,
                                OAbstractCommandTask task,
                                Set<String> nodes,
                                boolean executedLocally)

undoCommandOnLocalServer

protected void undoCommandOnLocalServer(OCommandRequestText iCommand)

executeOnServers

protected Map<String,Object> executeOnServers(OCommandRequestText iCommand,
                                              OCommandExecutor exec,
                                              Collection<String> involvedClusters,
                                              Map<String,Collection<String>> nodeClusterMap)

mergeResultByAggregation

protected Object mergeResultByAggregation(OCommandExecutorSQLSelect select,
                                          Map<String,Object> iResults)

executeOnlyLocally

protected boolean executeOnlyLocally(String localNodeName,
                                     ODistributedConfiguration dbCfg,
                                     OCommandExecutor exec,
                                     Collection<String> involvedClusters,
                                     Collection<String> nodes)

Only idempotent commands that don't involve any other node can be executed locally.

createRecord

public OStorageOperationResult<OPhysicalPosition> createRecord(ORecordId iRecordId,
                                                               byte[] iContent,
                                                               int iRecordVersion,
                                                               byte iRecordType,
                                                               int iMode,
                                                               ORecordCallback<Long> iCallback)

Specified by:

createRecord in interface OStorage

isLocalEnv

public boolean isLocalEnv()

Description copied from interface: OAutoshardedStorage

Check if the distributed need to run only as local env

Specified by:

isLocalEnv in interface OAutoshardedStorage

readRecord

public OStorageOperationResult<ORawBuffer> readRecord(ORecordId iRecordId,
                                                      String iFetchPlan,
                                                      boolean iIgnoreCache,
                                                      boolean prefetchRecords,
                                                      ORecordCallback<ORawBuffer> iCallback)

Specified by:

readRecord in interface OStorage

readRecordIfVersionIsNotLatest

public OStorageOperationResult<ORawBuffer> readRecordIfVersionIsNotLatest(ORecordId rid,
                                                                          String fetchPlan,
                                                                          boolean ignoreCache,
                                                                          int recordVersion)
                                                                   throws ORecordNotFoundException

Specified by:

readRecordIfVersionIsNotLatest in interface OStorage

Throws:

ORecordNotFoundException

deleteRecord

public OStorageOperationResult<Boolean> deleteRecord(ORecordId iRecordId,
                                                     int iVersion,
                                                     int iMode,
                                                     ORecordCallback<Boolean> iCallback)

Specified by:

deleteRecord in interface OStorage

getSBtreeCollectionManager

public OSBTreeCollectionManager getSBtreeCollectionManager()

Specified by:

getSBtreeCollectionManager in interface OStorage

checkWriteQuorum

protected void checkWriteQuorum(ODistributedConfiguration dbCfg,
                                String clusterName,
                                String localNodeName)

recyclePosition

public OStorageOperationResult<Integer> recyclePosition(ORecordId iRecordId,
                                                        byte[] iContent,
                                                        int iVersion,
                                                        byte iRecordType)

Description copied from interface: OStorage

Resurrects a record that was previously deleted, with a new content.

Specified by:

recyclePosition in interface OStorage

getConfigurationUpdated

public int getConfigurationUpdated()

hideRecord

public OStorageOperationResult<Boolean> hideRecord(ORecordId recordId,
                                                   int mode,
                                                   ORecordCallback<Boolean> callback)

Specified by:

hideRecord in interface OStorage

getRecordMetadata

public ORecordMetadata getRecordMetadata(ORID rid)

Specified by:

getRecordMetadata in interface OStorage

cleanOutRecord

public boolean cleanOutRecord(ORecordId recordId,
                              int recordVersion,
                              int iMode,
                              ORecordCallback<Boolean> callback)

Specified by:

cleanOutRecord in interface OStorage

existsResource

public boolean existsResource(String iName)

Specified by:

existsResource in interface OSharedContainer

getClusterRecordConflictStrategy

public ORecordConflictStrategy getClusterRecordConflictStrategy()

Specified by:

getClusterRecordConflictStrategy in interface OStorage

setConflictStrategy

public void setConflictStrategy(ORecordConflictStrategy iResolver)

Specified by:

setConflictStrategy in interface OStorage

removeResource

public <T> T removeResource(String iName)

Specified by:

removeResource in interface OSharedContainer

getResource

public <T> T getResource(String iName,
                         Callable<T> iCallback)

Specified by:

getResource in interface OSharedContainer

open

public void open(String iUserName,
                 String iUserPassword,
                 OContextConfiguration iProperties)

Specified by:

open in interface OStorage

create

public void create(OContextConfiguration iProperties)
            throws IOException

Specified by:

create in interface OStorage

Throws:

IOException

exists

public boolean exists()

Specified by:

exists in interface OStorage

reload

public void reload()

Specified by:

reload in interface OStorage

delete

public void delete()

Specified by:

delete in interface OStorage

incrementalBackup

public String incrementalBackup(String backupDirectory,
                                OCallable<Void,Void> started)

Specified by:

incrementalBackup in interface OStorage

Returns:

Backup file name

restoreFromIncrementalBackup

public void restoreFromIncrementalBackup(String filePath)

Specified by:

restoreFromIncrementalBackup in interface OStorage

supportIncremental

public boolean supportIncremental()

Specified by:

supportIncremental in interface OStorage

fullIncrementalBackup

public void fullIncrementalBackup(OutputStream stream)
                           throws UnsupportedOperationException

Specified by:

fullIncrementalBackup in interface OStorage

Throws:

UnsupportedOperationException

restoreFullIncrementalBackup

public void restoreFullIncrementalBackup(InputStream stream)
                                  throws UnsupportedOperationException

Specified by:

restoreFullIncrementalBackup in interface OStorage

Throws:

UnsupportedOperationException

close

public void close()

Specified by:

close in interface OStorage

close

public void close(boolean iForce,
                  boolean onDelete)

Specified by:

close in interface OStorage

closeOnDrop

public void closeOnDrop()

isClosed

public boolean isClosed()

Specified by:

isClosed in interface OStorage

commit

public List<ORecordOperation> commit(OTransactionInternal iTx)

Specified by:

commit in interface OStorage

acquireRecordLock

protected ODistributedRequestId acquireRecordLock(ORecordId rid)

releaseRecordLock

protected void releaseRecordLock(ORecordId rid,
                                 ODistributedRequestId requestId)

rollback

public void rollback(OTransactionInternal iTx)

Specified by:

rollback in interface OStorage

getConfiguration

public OStorageConfiguration getConfiguration()

Specified by:

getConfiguration in interface OStorage

getClusters

public int getClusters()

Specified by:

getClusters in interface OStorage

getClusterNames

public Set<String> getClusterNames()

Specified by:

getClusterNames in interface OStorage

addCluster

public int addCluster(String iClusterName,
                      Object... iParameters)

Description copied from interface: OStorage

Add a new cluster into the storage.

Specified by:

addCluster in interface OStorage

Parameters:

iClusterName - name of the cluster

addCluster

public int addCluster(String iClusterName,
                      int iRequestedId,
                      Object... iParameters)

Description copied from interface: OStorage

Add a new cluster into the storage.

Specified by:

addCluster in interface OStorage

Parameters:

iClusterName - name of the cluster

iRequestedId - requested id of the cluster

dropCluster

public boolean dropCluster(String iClusterName,
                           boolean iTruncate)

Specified by:

dropCluster in interface OStorage

dropCluster

public boolean dropCluster(int iId,
                           boolean iTruncate)

Description copied from interface: OStorage

Drops a cluster.

Specified by:

dropCluster in interface OStorage

Parameters:

iId - id of the cluster to delete

Returns:

true if has been removed, otherwise false

count

public long count(int iClusterId)

Specified by:

count in interface OStorage

count

public long count(int iClusterId,
                  boolean countTombstones)

Specified by:

count in interface OStorage

count

public long count(int[] iClusterIds)

Specified by:

count in interface OStorage

count

public long count(int[] iClusterIds,
                  boolean countTombstones)

Specified by:

count in interface OStorage

getSize

public long getSize()

Description copied from interface: OStorage

Returns the size of the database.

Specified by:

getSize in interface OStorage

countRecords

public long countRecords()

Description copied from interface: OStorage

Returns the total number of records.

Specified by:

countRecords in interface OStorage

getDefaultClusterId

public int getDefaultClusterId()

Specified by:

getDefaultClusterId in interface OStorage

setDefaultClusterId

public void setDefaultClusterId(int defaultClusterId)

Specified by:

setDefaultClusterId in interface OStorage

getClusterIdByName

public int getClusterIdByName(String iClusterName)

Specified by:

getClusterIdByName in interface OStorage

getPhysicalClusterNameById

public String getPhysicalClusterNameById(int iClusterId)

Specified by:

getPhysicalClusterNameById in interface OStorage

checkForRecordValidity

public boolean checkForRecordValidity(OPhysicalPosition ppos)

Specified by:

checkForRecordValidity in interface OStorage

getName

public String getName()

Specified by:

getName in interface OStorage

getURL

public String getURL()

Specified by:

getURL in interface OStorage

getVersion

public long getVersion()

Specified by:

getVersion in interface OStorage

synch

public void synch()

Specified by:

synch in interface OStorage

getClusterDataRange

public long[] getClusterDataRange(int currentClusterId)

Description copied from interface: OStorage

Returns a pair of long values telling the begin and end positions of data in the requested cluster. Useful to know the range of the records.

Specified by:

getClusterDataRange in interface OStorage

Parameters:

currentClusterId - Cluster id

getStatus

public OStorage.STATUS getStatus()

Description copied from interface: OStorage

Returns the current storage's status

Specified by:

getStatus in interface OStorage

getEventListener

public ODistributedStorageEventListener getEventListener()

setEventListener

public void setEventListener(ODistributedStorageEventListener eventListener)

higherPhysicalPositions

public OPhysicalPosition[] higherPhysicalPositions(int currentClusterId,
                                                   OPhysicalPosition entry)

Specified by:

higherPhysicalPositions in interface OStorage

getServer

public OServer getServer()

getDistributedManager

public ODistributedServerManager getDistributedManager()

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration()

setDistributedConfiguration

public void setDistributedConfiguration(OModifiableDistributedConfiguration distributedConfiguration)

ceilingPhysicalPositions

public OPhysicalPosition[] ceilingPhysicalPositions(int clusterId,
                                                    OPhysicalPosition physicalPosition)

Specified by:

ceilingPhysicalPositions in interface OStorage

floorPhysicalPositions

public OPhysicalPosition[] floorPhysicalPositions(int clusterId,
                                                  OPhysicalPosition physicalPosition)

Specified by:

floorPhysicalPositions in interface OStorage

lowerPhysicalPositions

public OPhysicalPosition[] lowerPhysicalPositions(int currentClusterId,
                                                  OPhysicalPosition entry)

Specified by:

lowerPhysicalPositions in interface OStorage

getUnderlying

public OStorage getUnderlying()

Specified by:

getUnderlying in interface OStorage

isRemote

public boolean isRemote()

Specified by:

isRemote in interface OStorage

getComponentsFactory

public OCurrentStorageComponentsFactory getComponentsFactory()

Specified by:

getComponentsFactory in interface OStorage

getType

public String getType()

Description copied from interface: OStorage

Returns the storage's type.

Specified by:

getType in interface OStorage

freeze

public void freeze(boolean throwException)

Description copied from interface: OFreezableStorageComponent

After this method finished it's execution, all threads that are going to perform data modifications in storage should wait till OFreezableStorageComponent.release() method will be called. This method will wait till all ongoing modifications will be finished.

Specified by:

freeze in interface OFreezableStorageComponent

Parameters:

throwException - If true OModificationOperationProhibitedException exception will be thrown on call of methods that requires storage modification. Otherwise other threads will wait for OFreezableStorageComponent.release() method call.

release

public void release()

Description copied from interface: OFreezableStorageComponent

After this method finished execution all threads that are waiting to perform data modifications in storage will be awaken and will be allowed to continue their execution.

Specified by:

release in interface OFreezableStorageComponent

backup

public List<String> backup(OutputStream out,
                           Map<String,Object> options,
                           Callable<Object> callable,
                           OCommandOutputListener iListener,
                           int compressionLevel,
                           int bufferSize)
                    throws IOException

Description copied from interface: OBackupable

Executes a backup of the database. During the backup the database will be frozen in read-only mode.

Specified by:

backup in interface OBackupable

Parameters:

out - OutputStream used to write the backup content. Use a FileOutputStream to make the backup persistent on disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

compressionLevel - ZIP Compression level between 1 (the minimum) and 9 (maximum). The bigger is the compression, the smaller will be the final backup content, but will consume more CPU and time to execute

bufferSize - Buffer size in bytes, the bigger is the buffer, the more efficient will be the compression

Throws:

IOException

See Also:

ODatabaseExport

restore

public void restore(InputStream in,
                    Map<String,Object> options,
                    Callable<Object> callable,
                    OCommandOutputListener iListener)
             throws IOException

Description copied from interface: OBackupable

Executes a restore of a database backup. During the restore the database will be frozen in read-only mode.

Specified by:

restore in interface OBackupable

Parameters:

in - InputStream used to read the backup content. Use a FileInputStream to read a backup on a disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

Throws:

IOException

See Also:

ODatabaseImport

getClusterNameByRID

public String getClusterNameByRID(ORecordId iRid)

getClusterNameById

public String getClusterNameById(int clusterId)

Specified by:

getClusterNameById in interface OStorage

getClusterRecordsSizeById

public long getClusterRecordsSizeById(int clusterId)

Specified by:

getClusterRecordsSizeById in interface OStorage

getClusterRecordsSizeByName

public long getClusterRecordsSizeByName(String clusterName)

Specified by:

getClusterRecordsSizeByName in interface OStorage

truncateCluster

public void truncateCluster(String clusterName)

Specified by:

truncateCluster in interface OStorage

setClusterAttribute

public void setClusterAttribute(int clusterId,
                                OCluster.ATTRIBUTES attribute,
                                Object value)

Specified by:

setClusterAttribute in interface OStorage

setClusterAttribute

public Object setClusterAttribute(String clusterName,
                                  OCluster.ATTRIBUTES attribute,
                                  Object value)

Specified by:

setClusterAttribute in interface OStorage

getClusterRecordConflictStrategy

public String getClusterRecordConflictStrategy(int clusterId)

Specified by:

getClusterRecordConflictStrategy in interface OStorage

getClusterEncryption

public String getClusterEncryption(int clusterId)

Specified by:

getClusterEncryption in interface OStorage

isSystemCluster

public boolean isSystemCluster(int clusterId)

Specified by:

isSystemCluster in interface OStorage

getLastClusterPosition

public long getLastClusterPosition(int clusterId)

Specified by:

getLastClusterPosition in interface OStorage

getClusterNextPosition

public long getClusterNextPosition(int clusterId)

Specified by:

getClusterNextPosition in interface OStorage

getRecordStatus

public OPaginatedCluster.RECORD_STATUS getRecordStatus(ORID rid)

Specified by:

getRecordStatus in interface OStorage

getStorageId

public String getStorageId()

Description copied from interface: OAutoshardedStorage

Storage unique id, made by node name + database name

Specified by:

getStorageId in interface OAutoshardedStorage

Returns:

storage unique id

getNodeId

public String getNodeId()

Specified by:

getNodeId in interface OAutoshardedStorage

shutdown

public void shutdown()

Description copied from interface: OStorage

This method is called in Orient.shutdown() method. For most of the storages it means that storage will be merely closed, but sometimes additional operations are need to be taken in account.

Specified by:

shutdown in interface OStorage

shutdownAsynchronousWorker

public void shutdownAsynchronousWorker()

checkNodeIsMaster

protected void checkNodeIsMaster(String localNodeName,
                                 ODistributedConfiguration dbCfg,
                                 String operation)

getLastValidBackup

public OSyncSource getLastValidBackup()

setLastValidBackup

public void setLastValidBackup(OSyncSource lastValidBackup)

asynchronousExecution

protected void asynchronousExecution(OAsynchDistributedOperation iOperation)

getAsyncReplicationError

protected OAsyncReplicationError getAsyncReplicationError()

handleDistributedException

protected void handleDistributedException(String iMessage,
                                          Exception e,
                                          Object... iParams)

resetLastValidBackup

public void resetLastValidBackup()

clearLastValidBackup

public void clearLastValidBackup()

dropStorageFiles

protected void dropStorageFiles()

dropStorageFiles

public static void dropStorageFiles(OAbstractPaginatedStorage wrapped)

checkForCluster

protected String checkForCluster(ORecord record,
                                 String localNodeName,
                                 ODistributedConfiguration dbCfg)

loadDatabaseConfiguration

public ODocument loadDatabaseConfiguration(File file)

saveDatabaseConfiguration

protected void saveDatabaseConfiguration()

getDistributedConfigFile

protected File getDistributedConfigFile()

getLocalDistributedDatabase

public ODistributedDatabase getLocalDistributedDatabase()

setSchemaRecordId

public void setSchemaRecordId(String schemaRecordId)

Specified by:

setSchemaRecordId in interface OStorage

setDateFormat

public void setDateFormat(String dateFormat)

Specified by:

setDateFormat in interface OStorage

setTimeZone

public void setTimeZone(TimeZone timeZoneValue)

Specified by:

setTimeZone in interface OStorage

setLocaleLanguage

public void setLocaleLanguage(String locale)

Specified by:

setLocaleLanguage in interface OStorage

setCharset

public void setCharset(String charset)

Specified by:

setCharset in interface OStorage

setIndexMgrRecordId

public void setIndexMgrRecordId(String indexMgrRecordId)

Specified by:

setIndexMgrRecordId in interface OStorage

setDateTimeFormat

public void setDateTimeFormat(String dateTimeFormat)

Specified by:

setDateTimeFormat in interface OStorage

setLocaleCountry

public void setLocaleCountry(String localeCountry)

Specified by:

setLocaleCountry in interface OStorage

setClusterSelection

public void setClusterSelection(String clusterSelection)

Specified by:

setClusterSelection in interface OStorage

setMinimumClusters

public void setMinimumClusters(int minimumClusters)

Specified by:

setMinimumClusters in interface OStorage

setValidation

public void setValidation(boolean validation)

Specified by:

setValidation in interface OStorage

removeProperty

public void removeProperty(String property)

Specified by:

removeProperty in interface OStorage

setProperty

public void setProperty(String property,
                        String value)

Specified by:

setProperty in interface OStorage

setRecordSerializer

public void setRecordSerializer(String recordSerializer,
                                int version)

Specified by:

setRecordSerializer in interface OStorage

clearProperties

public void clearProperties()

Specified by:

clearProperties in interface OStorage