Package com.orientechnologies.orient.core.storage.config

Class OClusterBasedStorageConfiguration

java.lang.Object

com.orientechnologies.orient.core.storage.config.OClusterBasedStorageConfiguration

All Implemented Interfaces:

OStorageConfiguration

public final class OClusterBasedStorageConfiguration
extends Object
implements OStorageConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COMPONENT_NAME
static final String	DATA_FILE_EXTENSION
static final String	FREE_MAP_FILE_EXTENSION
static final String	MAP_FILE_EXTENSION
static final String	TREE_DATA_FILE_EXTENSION
static final String	TREE_NULL_FILE_EXTENSION

Fields inherited from interface com.orientechnologies.orient.core.config.OStorageConfiguration

CURRENT_BINARY_FORMAT_VERSION, CURRENT_VERSION, DEFAULT_CHARSET, DEFAULT_DATE_FORMAT, DEFAULT_DATETIME_FORMAT

Constructor Summary

Constructors

Constructor	Description
OClusterBasedStorageConfiguration(OAbstractPaginatedStorage storage)

Method Summary

Modifier and Type	Method	Description
void	addIndexEngine(OAtomicOperation atomicOperation, String name, IndexEngineData engineData)
void	clearProperties(OAtomicOperation atomicOperation)
void	close(OAtomicOperation atomicOperation)
void	create(OAtomicOperation atomicOperation, OContextConfiguration contextConfiguration)
void	create(OAtomicOperation atomicOperation, OContextConfiguration contextConfiguration, OStorageConfiguration source)
void	delete(OAtomicOperation atomicOperation)
void	deleteIndexEngine(OAtomicOperation atomicOperation, String name)
void	dropCluster(OAtomicOperation atomicOperation, int clusterId)
static boolean	exists(OWriteCache writeCache)
void	fireUpdateNotifications()
int	getBinaryFormatVersion()
String	getCharset()
List<OStorageClusterConfiguration>	getClusters()
String	getClusterSelection()
String	getConflictStrategy()
OContextConfiguration	getContextConfiguration()
String	getCreatedAtVersion()
String	getDateFormat()
SimpleDateFormat	getDateFormatInstance()
String	getDateTimeFormat()
SimpleDateFormat	getDateTimeFormatInstance()
String	getDirectory()
int	getFreeListBoundary()
IndexEngineData	getIndexEngine(String name, int defaultIndexId)
String	getIndexMgrRecordId()
String	getLocaleCountry()
Locale	getLocaleInstance()
String	getLocaleLanguage()
int	getMaxKeySize()
int	getMinimumClusters()
String	getName()
int	getPageSize()
List<OStorageEntryConfiguration>	getProperties()
String	getProperty(String name)
String	getRecordSerializer()
int	getRecordSerializerVersion()
String	getSchemaRecordId()
TimeZone	getTimeZone()
String	getUuid()
int	getVersion()
Set<String>	indexEngines()
boolean	isStrictSql()
boolean	isValidationEnabled()
void	load(OContextConfiguration configuration, OAtomicOperation atomicOperation)
void	pauseUpdateNotifications()
void	removeProperty(OAtomicOperation atomicOperation, String name)
void	setCharset(OAtomicOperation atomicOperation, String charset)
void	setClusterSelection(OAtomicOperation atomicOperation, String clusterSelection)
void	setClusterStatus(OAtomicOperation atomicOperation, int clusterId, OStorageClusterConfiguration.STATUS status)
void	setConfigurationUpdateListener(OStorageConfigurationUpdateListener updateListener)
void	setConflictStrategy(OAtomicOperation atomicOperation, String conflictStrategy)
void	setCreationVersion(OAtomicOperation atomicOperation, String version)
void	setDateFormat(OAtomicOperation atomicOperation, String dateFormat)
void	setDateTimeFormat(OAtomicOperation atomicOperation, String dateTimeFormat)
void	setFreeListBoundary(OAtomicOperation atomicOperation, int freeListBoundary)
void	setIndexMgrRecordId(OAtomicOperation atomicOperation, String indexMgrRecordId)
void	setLocaleCountry(OAtomicOperation atomicOperation, String value)
void	setLocaleLanguage(OAtomicOperation atomicOperation, String value)
void	setMaxKeySize(OAtomicOperation atomicOperation, int maxKeySize)
void	setMinimumClusters(int minimumClusters)
void	setPageSize(OAtomicOperation atomicOperation, int pageSize)
void	setProperty(OAtomicOperation atomicOperation, String name, String value)
void	setRecordSerializer(OAtomicOperation atomicOperation, String recordSerializer)
void	setRecordSerializerVersion(OAtomicOperation atomicOperation, int recordSerializerVersion)
void	setSchemaRecordId(OAtomicOperation atomicOperation, String schemaRecordId)
void	setTimeZone(OAtomicOperation atomicOperation, TimeZone timeZone)
void	setUuid(OAtomicOperation atomicOperation, String uuid)
void	setValidation(OAtomicOperation atomicOperation, boolean validation)
byte[]	toStream(int iNetworkVersion, Charset charset)	Added version used for managed Network Versioning.
void	updateCluster(OAtomicOperation atomicOperation, OStorageClusterConfiguration config)

Methods inherited from class java.lang.Object

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

Field Details

MAP_FILE_EXTENSION

public static final String MAP_FILE_EXTENSION

See Also:

• Constant Field Values

FREE_MAP_FILE_EXTENSION

public static final String FREE_MAP_FILE_EXTENSION

See Also:

• Constant Field Values

DATA_FILE_EXTENSION

public static final String DATA_FILE_EXTENSION

See Also:

• Constant Field Values

TREE_DATA_FILE_EXTENSION

public static final String TREE_DATA_FILE_EXTENSION

See Also:

• Constant Field Values

TREE_NULL_FILE_EXTENSION

public static final String TREE_NULL_FILE_EXTENSION

See Also:

• Constant Field Values

COMPONENT_NAME

public static final String COMPONENT_NAME

See Also:

• Constant Field Values

Constructor Details

OClusterBasedStorageConfiguration

public OClusterBasedStorageConfiguration(OAbstractPaginatedStorage storage)

Method Details

exists

public static boolean exists(OWriteCache writeCache)

create

public void create(OAtomicOperation atomicOperation,
 OContextConfiguration contextConfiguration)
            throws IOException

Throws:

IOException

create

public void create(OAtomicOperation atomicOperation,
 OContextConfiguration contextConfiguration,
 OStorageConfiguration source)
            throws IOException

Throws:

IOException

delete

public void delete(OAtomicOperation atomicOperation)
            throws IOException

Throws:

IOException

close

public void close(OAtomicOperation atomicOperation)

load

public void load(OContextConfiguration configuration,
 OAtomicOperation atomicOperation)
          throws OSerializationException,
IOException

Throws:

OSerializationException

IOException

pauseUpdateNotifications

public void pauseUpdateNotifications()

fireUpdateNotifications

public void fireUpdateNotifications()

setMinimumClusters

public void setMinimumClusters(int minimumClusters)

getMinimumClusters

public int getMinimumClusters()

Specified by:

getMinimumClusters in interface OStorageConfiguration

getContextConfiguration

public OContextConfiguration getContextConfiguration()

Specified by:

getContextConfiguration in interface OStorageConfiguration

toStream

public byte[] toStream(int iNetworkVersion,
 Charset charset)
                throws OSerializationException

Added version used for managed Network Versioning.

Throws:

OSerializationException

getVersion

public int getVersion()

Specified by:

getVersion in interface OStorageConfiguration

getName

public String getName()

Specified by:

getName in interface OStorageConfiguration

setSchemaRecordId

public void setSchemaRecordId(OAtomicOperation atomicOperation,
 String schemaRecordId)

getSchemaRecordId

public String getSchemaRecordId()

Specified by:

getSchemaRecordId in interface OStorageConfiguration

setIndexMgrRecordId

public void setIndexMgrRecordId(OAtomicOperation atomicOperation,
 String indexMgrRecordId)

getIndexMgrRecordId

public String getIndexMgrRecordId()

Specified by:

getIndexMgrRecordId in interface OStorageConfiguration

setLocaleLanguage

public void setLocaleLanguage(OAtomicOperation atomicOperation,
 String value)

getLocaleLanguage

public String getLocaleLanguage()

Specified by:

getLocaleLanguage in interface OStorageConfiguration

setLocaleCountry

public void setLocaleCountry(OAtomicOperation atomicOperation,
 String value)

getLocaleCountry

public String getLocaleCountry()

Specified by:

getLocaleCountry in interface OStorageConfiguration

setDateFormat

public void setDateFormat(OAtomicOperation atomicOperation,
 String dateFormat)

getDateFormat

public String getDateFormat()

Specified by:

getDateFormat in interface OStorageConfiguration

getDateFormatInstance

public SimpleDateFormat getDateFormatInstance()

Specified by:

getDateFormatInstance in interface OStorageConfiguration

getDateTimeFormat

public String getDateTimeFormat()

Specified by:

getDateTimeFormat in interface OStorageConfiguration

setDateTimeFormat

public void setDateTimeFormat(OAtomicOperation atomicOperation,
 String dateTimeFormat)

setUuid

public void setUuid(OAtomicOperation atomicOperation,
 String uuid)

Specified by:

setUuid in interface OStorageConfiguration

getUuid

public String getUuid()

Specified by:

getUuid in interface OStorageConfiguration

getDateTimeFormatInstance

public SimpleDateFormat getDateTimeFormatInstance()

Specified by:

getDateTimeFormatInstance in interface OStorageConfiguration

setTimeZone

public void setTimeZone(OAtomicOperation atomicOperation,
 TimeZone timeZone)

getTimeZone

public TimeZone getTimeZone()

Specified by:

getTimeZone in interface OStorageConfiguration

setCharset

public void setCharset(OAtomicOperation atomicOperation,
 String charset)

getCharset

public String getCharset()

Specified by:

getCharset in interface OStorageConfiguration

setConflictStrategy

public void setConflictStrategy(OAtomicOperation atomicOperation,
 String conflictStrategy)

getConflictStrategy

public String getConflictStrategy()

Specified by:

getConflictStrategy in interface OStorageConfiguration

getBinaryFormatVersion

public int getBinaryFormatVersion()

Specified by:

getBinaryFormatVersion in interface OStorageConfiguration

setClusterSelection

public void setClusterSelection(OAtomicOperation atomicOperation,
 String clusterSelection)

getClusterSelection

public String getClusterSelection()

Specified by:

getClusterSelection in interface OStorageConfiguration

setRecordSerializer

public void setRecordSerializer(OAtomicOperation atomicOperation,
 String recordSerializer)

getRecordSerializer

public String getRecordSerializer()

Specified by:

getRecordSerializer in interface OStorageConfiguration

setRecordSerializerVersion

public void setRecordSerializerVersion(OAtomicOperation atomicOperation,
 int recordSerializerVersion)

getRecordSerializerVersion

public int getRecordSerializerVersion()

Specified by:

getRecordSerializerVersion in interface OStorageConfiguration

setCreationVersion

public void setCreationVersion(OAtomicOperation atomicOperation,
 String version)

getCreatedAtVersion

public String getCreatedAtVersion()

Specified by:

getCreatedAtVersion in interface OStorageConfiguration

setPageSize

public void setPageSize(OAtomicOperation atomicOperation,
 int pageSize)

getPageSize

public int getPageSize()

Specified by:

getPageSize in interface OStorageConfiguration

setFreeListBoundary

public void setFreeListBoundary(OAtomicOperation atomicOperation,
 int freeListBoundary)

getFreeListBoundary

public int getFreeListBoundary()

Specified by:

getFreeListBoundary in interface OStorageConfiguration

setMaxKeySize

public void setMaxKeySize(OAtomicOperation atomicOperation,
 int maxKeySize)

getMaxKeySize

public int getMaxKeySize()

Specified by:

getMaxKeySize in interface OStorageConfiguration

setProperty

public void setProperty(OAtomicOperation atomicOperation,
 String name,
 String value)

setValidation

public void setValidation(OAtomicOperation atomicOperation,
 boolean validation)

isValidationEnabled

public boolean isValidationEnabled()

Specified by:

isValidationEnabled in interface OStorageConfiguration

getDirectory

public String getDirectory()

Specified by:

getDirectory in interface OStorageConfiguration

getProperty

public String getProperty(String name)

Specified by:

getProperty in interface OStorageConfiguration

getProperties

public List<OStorageEntryConfiguration> getProperties()

Specified by:

getProperties in interface OStorageConfiguration

getLocaleInstance

public Locale getLocaleInstance()

Specified by:

getLocaleInstance in interface OStorageConfiguration

isStrictSql

public boolean isStrictSql()

Specified by:

isStrictSql in interface OStorageConfiguration

clearProperties

public void clearProperties(OAtomicOperation atomicOperation)

removeProperty

public void removeProperty(OAtomicOperation atomicOperation,
 String name)

addIndexEngine

public void addIndexEngine(OAtomicOperation atomicOperation,
 String name,
 IndexEngineData engineData)

deleteIndexEngine

public void deleteIndexEngine(OAtomicOperation atomicOperation,
 String name)

indexEngines

public Set<String> indexEngines()

Specified by:

indexEngines in interface OStorageConfiguration

getIndexEngine

public IndexEngineData getIndexEngine(String name,
 int defaultIndexId)

Specified by:

getIndexEngine in interface OStorageConfiguration

updateCluster

public void updateCluster(OAtomicOperation atomicOperation,
 OStorageClusterConfiguration config)

setClusterStatus

public void setClusterStatus(OAtomicOperation atomicOperation,
 int clusterId,
 OStorageClusterConfiguration.STATUS status)

getClusters

public List<OStorageClusterConfiguration> getClusters()

Specified by:

getClusters in interface OStorageConfiguration

dropCluster

public void dropCluster(OAtomicOperation atomicOperation,
 int clusterId)

setConfigurationUpdateListener

public void setConfigurationUpdateListener(OStorageConfigurationUpdateListener updateListener)