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, OStorageInfo, 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)
int	addCluster(String iClusterName, int iRequestedId) Add a new cluster into the storage.
int	addCluster(String iClusterName, Object... iParameters) Add a new cluster into the storage.
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)
boolean	checkForRecordValidity(OPhysicalPosition ppos)
protected void	checkNodeIsMaster(String localNodeName, ODistributedConfiguration dbCfg, String operation)
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)
void	delete()
OStorageOperationResult<Boolean>	deleteRecord(ORecordId iRecordId, int iVersion, int iMode, ORecordCallback<Boolean> iCallback)
boolean	dropCluster(int iId) Drops a cluster.
boolean	dropCluster(String iClusterName)
protected void	dropStorageFiles()
static void	dropStorageFiles(OLocalPaginatedStorage storage)
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)
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)
Collection<? extends OCluster>	getClusterInstances()
String	getClusterName(int clusterId)
String	getClusterNameById(int clusterId)
String	getClusterNameByRID(ORecordId iRid)
Set<String>	getClusterNames()
long	getClusterNextPosition(int clusterId)
String	getClusterRecordConflictStrategy(int clusterId)
long	getClusterRecordsSizeById(int clusterId)
long	getClusterRecordsSizeByName(String clusterName)
int	getClusters()
OCurrentStorageComponentsFactory	getComponentsFactory()
OStorageConfiguration	getConfiguration()
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)
ORecordConflictStrategy	getRecordConflictStrategy()
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)
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)
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)
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()
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)
protected void	saveDatabaseConfiguration()
void	setCharset(String charset)
boolean	setClusterAttribute(int id, OCluster.ATTRIBUTES attribute, Object value)
boolean	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.
boolean	supportIncremental()
void	synch()
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.

isDistributed

public boolean isDistributed()

Specified by:

isDistributed in interface OStorage

isAssigningClusterIds

public boolean isAssigningClusterIds()

Specified by:

isAssigningClusterIds in interface OStorage

Specified by:

isAssigningClusterIds in interface OStorageInfo

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

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

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

getClusterName

public String getClusterName(int clusterId)

Specified by:

getClusterName in interface OStorage

setClusterAttribute

public boolean setClusterAttribute(int id,
                                   OCluster.ATTRIBUTES attribute,
                                   Object value)

Specified by:

setClusterAttribute in interface OStorage

getRecordConflictStrategy

public ORecordConflictStrategy getRecordConflictStrategy()

Specified by:

getRecordConflictStrategy 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

getConfiguration

public OStorageConfiguration getConfiguration()

Specified by:

getConfiguration in interface OStorageInfo

getClusters

public int getClusters()

Specified by:

getClusters in interface OStorageInfo

getClusterNames

public Set<String> getClusterNames()

Specified by:

getClusterNames in interface OStorage

Specified by:

getClusterNames in interface OStorageInfo

getClusterInstances

public Collection<? extends OCluster> getClusterInstances()

Specified by:

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

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)

Specified by:

dropCluster in interface OStorage

dropCluster

public boolean dropCluster(int iId)

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

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

setClusterAttribute

public boolean 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

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 OStorageInfo

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 OStorageInfo

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)

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

checkNodeIsMaster

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

getLastValidBackup

public OSyncSource getLastValidBackup()

setLastValidBackup

public void setLastValidBackup(OSyncSource lastValidBackup)

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

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