OAbstractPaginatedStorage (OrientDB 3.0.44 API)

java.lang.Object
- com.orientechnologies.orient.core.storage.OStorageAbstract
- - com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

All Implemented Interfaces:

OSharedContainer, OBackgroundExceptionListener, OCheckpointRequestListener, OFreezableStorageComponent, OLowDiskSpaceListener, OPageIsBrokenListener, OIdentifiableStorage, OStorage, OBackupable

Direct Known Subclasses:

ODirectMemoryStorage, OLocalPaginatedStorage
```
public abstract class OAbstractPaginatedStorage
extends OStorageAbstract
implements OLowDiskSpaceListener, OCheckpointRequestListener, OIdentifiableStorage, OBackgroundExceptionListener, OFreezableStorageComponent, OPageIsBrokenListener
```
Since:

28.03.13

Author:

Andrey Lomakin (a.lomakin-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
Modifier and Type	Field and Description
`protected OAtomicOperationsManager`	`atomicOperationsManager`
`protected AtomicOperationsTable`	`atomicOperationsTable`
`protected static String`	`DATABASE_INSTANCE_ID`
`protected static OScheduledThreadPoolExecutorWithLogging`	`fuzzyCheckpointExecutor`
`protected OStorageInterruptionManager`	`interruptionManager`
`protected OReadCache`	`readCache`
`protected OSBTreeCollectionManagerShared`	`sbTreeCollectionManager`
`protected OWriteAheadLog`	`writeAheadLog`
`protected OWriteCache`	`writeCache`

Fields inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract
componentsFactory, configuration, mode, name, sharedContainer, stateLock, status, storageThreadGroup, url

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

Constructor Summary

Constructors
Constructor and Description
`OAbstractPaginatedStorage(String name, String filePath, String mode, int id)`

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`acquireReadLock(ORID rid)`
`void`	`acquireWriteLock(ORID rid)`
`int`	`addCluster(String clusterName, int requestedId, Object... parameters)` Add a new cluster into the storage.
`int`	`addCluster(String clusterName, Object... parameters)` Add a new cluster into the storage.
`protected abstract void`	`addFileToDirectory(String name, InputStream stream, File directory)`
`int`	`addIndexEngine(String engineName, String algorithm, String indexType, OIndexDefinition indexDefinition, OBinarySerializer<?> valueSerializer, boolean isAutomatic, Boolean durableInNonTxMode, int version, int apiVersion, boolean multivalue, Map<String,String> engineProperties, Set<String> clustersToIndex, ODocument metadata)`
`Iterator<OClusterBrowsePage>`	`browseCluster(int clusterId)`
`<T> T`	`callIndexEngine(boolean atomicOperation, boolean readOperation, int indexId, OIndexEngineCallback<T> callback)`
`OPhysicalPosition[]`	`ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)`
`boolean`	`check(boolean verbose, OCommandOutputListener listener)`
`protected void`	`checkDatabaseInstanceId(UUID backupUUID)`
`boolean`	`checkForRecordValidity(OPhysicalPosition ppos)`
`protected long`	`checkIfStorageDirty()`
`protected void`	`checkOpenness()` Checks if the storage is open.
`void`	`checkReadOnlyConditions()`
`boolean`	`cleanOutRecord(ORecordId recordId, int recordVersion, int iMode, ORecordCallback<Boolean> callback)`
`void`	`clearIndex(int indexId)`
`void`	`clearProperties()`
`protected void`	`clearStorageDirty()`
`void`	`close(boolean force, boolean onDelete)`
`protected void`	`closeClusters(boolean onDelete)`
`protected void`	`closeIndexes(boolean onDelete)`
`Object`	`command(OCommandRequestText iCommand)` Executes the command request and return the result back.
`List<ORecordOperation>`	`commit(OTransactionInternal clientTx)` Traditional commit that support already temporary rid and already assigned rids
`protected List<ORecordOperation>`	`commit(OTransactionInternal transaction, boolean allocated)` The commit operation can be run in 3 different conditions, embedded commit, pre-allocated commit, other node commit.
`List<ORecordOperation>`	`commitPreAllocated(OTransactionInternal clientTx)` Commit a transaction where the rid where pre-allocated in a previous phase
`OSessionStoragePerformanceStatistic`	`completeGatheringPerformanceStatisticForCurrentThread()` Completes gathering performance characteristics for current thread initiated by call of `startGatheringPerformanceStatisticForCurrentThread()`
`protected abstract OLogSequenceNumber`	`copyWALToIncrementalBackup(ZipOutputStream zipOutputStream, long startSegment)`
`long`	`count(int iClusterId)`
`long`	`count(int[] iClusterIds)`
`long`	`count(int[] iClusterIds, boolean countTombstones)`
`long`	`count(int clusterId, boolean countTombstones)`
`long`	`countRecords()` Returns the total number of records.
`void`	`create(OContextConfiguration contextConfiguration)`
`OStorageOperationResult<OPhysicalPosition>`	`createRecord(ORecordId rid, byte[] content, int recordVersion, byte recordType, int mode, ORecordCallback<Long> callback)`
`protected abstract OWriteAheadLog`	`createWalFromIBUFiles(File directory, OContextConfiguration contextConfiguration, Locale locale)`
`protected abstract File`	`createWalTempDirectory()`
`void`	`delete()`
`void`	`deleteIndexEngine(int indexId)`
`OStorageOperationResult<Boolean>`	`deleteRecord(ORecordId rid, int version, int mode, ORecordCallback<Boolean> callback)`
`boolean`	`dropCluster(int clusterId, boolean iTruncate)` Drops a cluster.
`Object`	`executeCommand(OCommandRequestText iCommand, OCommandExecutor executor)`
`static int`	`extractEngineAPIVersion(int externalId)`
`void`	`fireConfigurationUpdateNotifications()`
`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 void`	`generateDatabaseInstanceId(OAtomicOperation atomicOperation)`
`OAtomicOperationsManager`	`getAtomicOperationsManager()`
`long[]`	`getClusterDataRange(int iClusterId)` 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 clusterName)`
`String`	`getClusterNameById(int clusterId)`
`Set<String>`	`getClusterNames()`
`long`	`getClusterNextPosition(int clusterId)`
`ORecordConflictStrategy`	`getClusterRecordConflictStrategy()`
`String`	`getClusterRecordConflictStrategy(int clusterId)`
`long`	`getClusterRecordsSizeById(int clusterId)`
`long`	`getClusterRecordsSizeByName(String clusterName)`
`int`	`getClusters()`
`OStorageConfiguration`	`getConfiguration()`
`String`	`getCreatedAtVersion()`
`int`	`getDefaultClusterId()`
`long`	`getFullCheckpointCount()`
`int`	`getId()`
`AtomicOperationIdGen`	`getIdGen()`
`OIndexCursor`	`getIndexCursor(int indexId, OBaseIndexEngine.ValuesTransformer valuesTransformer)`
`OIndexCursor`	`getIndexDescCursor(int indexId, OBaseIndexEngine.ValuesTransformer valuesTransformer)`
`OBaseIndexEngine`	`getIndexEngine(int indexId)`
`Object`	`getIndexFirstKey(int indexId)`
`OIndexKeyCursor`	`getIndexKeyCursor(int indexId)`
`Object`	`getIndexLastKey(int indexId)`
`long`	`getIndexSize(int indexId, OBaseIndexEngine.ValuesTransformer transformer)`
`Object`	`getIndexValue(int indexId, Object key)`
`long`	`getLastCloseTime()`
`long`	`getLastClusterPosition(int clusterId)`
`OLogSequenceNumber`	`getLSN()`
`String`	`getMode()`
`protected OPerformanceStatisticManager`	`getPerformanceStatisticManager()`
`String`	`getPhysicalClusterNameById(int iClusterId)`
`OReadCache`	`getReadCache()`
`ORecordMetadata`	`getRecordMetadata(ORID rid)`
`AtomicLong`	`getRecordScanned()`
`OPaginatedCluster.RECORD_STATUS`	`getRecordStatus(ORID rid)`
`OStorageRecoverListener`	`getRecoverListener()`
`protected static Map<Integer,List<ORecordId>>`	`getRidsGroupedByCluster(Collection<ORecordId> rids)`
`OSBTreeCollectionManager`	`getSBtreeCollectionManager()`
`int`	`getSessionCount()`
`long`	`getSize()` Returns the size of the database.
`OStorageTransaction`	`getStorageTransaction()`
`OWriteAheadLog`	`getWALInstance()`
`OWriteCache`	`getWriteCache()`
`void`	`handleJVMError(Error e)` That is internal method which is called once we encounter any error inside of JVM.
`boolean`	`hasIndexRangeQuerySupport(int indexId)`
`OStorageOperationResult<Boolean>`	`hideRecord(ORecordId rid, int mode, ORecordCallback<Boolean> callback)`
`OPhysicalPosition[]`	`higherPhysicalPositions(int currentClusterId, OPhysicalPosition physicalPosition)`
`void`	`incOnOpen()`
`String`	`incrementalBackup(String backupDirectory, OCallable<Void,Void> started)`
`boolean`	`indexContainsKey(int indexId, Object key)`
`protected void`	`initConfiguration(OAtomicOperation atomicOperation, OContextConfiguration contextConfiguration)`
`protected abstract void`	`initWalAndDiskCache(OContextConfiguration contextConfiguration)`
`void`	`interruptExecution(Thread thread)` forces interruption of this execution
`boolean`	`isClosed()`
`boolean`	`isDeleted(ORID rid)`
`protected boolean`	`isDirty()`
`boolean`	`isRemote()`
`boolean`	`isSystemCluster(int clusterId)`
`protected abstract boolean`	`isWriteAllowedDuringIncrementalBackup()`
`OIndexCursor`	`iterateIndexEntriesBetween(int indexId, Object rangeFrom, boolean fromInclusive, Object rangeTo, boolean toInclusive, boolean ascSortOrder, OBaseIndexEngine.ValuesTransformer transformer)`
`OIndexCursor`	`iterateIndexEntriesMajor(int indexId, Object fromKey, boolean isInclusive, boolean ascSortOrder, OBaseIndexEngine.ValuesTransformer transformer)`
`OIndexCursor`	`iterateIndexEntriesMinor(int indexId, Object toKey, boolean isInclusive, boolean ascSortOrder, OBaseIndexEngine.ValuesTransformer transformer)`
`int`	`loadExternalIndexEngine(String engineName, String algorithm, String indexType, OIndexDefinition indexDefinition, OBinarySerializer<?> valueSerializer, boolean isAutomatic, Boolean durableInNonTxMode, int version, int apiVersion, boolean multivalue, Map<String,String> engineProperties)`
`int`	`loadIndexEngine(String name)`
`protected Error`	`logAndPrepareForRethrow(Error error)`
`protected RuntimeException`	`logAndPrepareForRethrow(RuntimeException runtimeException)`
`protected RuntimeException`	`logAndPrepareForRethrow(Throwable throwable)`
`void`	`lowDiskSpace(OLowDiskSpaceInformation information)`
`OPhysicalPosition[]`	`lowerPhysicalPositions(int currentClusterId, OPhysicalPosition physicalPosition)`
`protected void`	`makeFullCheckpoint()`
`protected void`	`makeFuzzyCheckpoint()`
`protected void`	`makeStorageDirty()`
`void`	`onException(Throwable e)`
`void`	`open(OContextConfiguration contextConfiguration)`
`void`	`open(OToken iToken, OContextConfiguration configuration)`
`void`	`open(String iUserName, String iUserPassword, OContextConfiguration contextConfiguration)`
`protected void`	`openClusters()`
`protected void`	`openIndexes()`
`void`	`pageIsBroken(String fileName, long pageIndex)` Method is called by write cache when it is detected that data page in file is broken.
`void`	`pauseConfigurationUpdateNotifications()`
`protected abstract void`	`postCloseSteps(boolean onDelete, boolean jvmError, long lastTxId)`
`protected void`	`postCloseStepsAfterLock(Map<String,Object> params)`
`protected void`	`postCreateSteps()`
`protected void`	`postDeleteSteps()`
`void`	`preallocateRids(OTransactionInternal clientTx)` Scan the given transaction for new record and allocate a record id for them, the relative record id is inserted inside the transaction for future use.
`protected Map<String,Object>`	`preCloseSteps()`
`protected void`	`preCreateSteps()`
`void`	`putIndexValue(int indexId, Object key, Object value)`
`void`	`putRidIndexEntry(int indexId, Object key, ORID value)`
`protected UUID`	`readDatabaseInstanceId()`
`OStorageOperationResult<ORawBuffer>`	`readRecord(ORecordId iRid, String iFetchPlan, boolean iIgnoreCache, boolean prefetchRecords, ORecordCallback<ORawBuffer> iCallback)`
`OStorageOperationResult<ORawBuffer>`	`readRecordIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion)`
`OBackgroundDelta`	`recordsChangedAfterLSN(OLogSequenceNumber lsn, OCommandOutputListener outputListener)` This method finds all the records which were updated starting from (but not including) current LSN and write result in provided output stream.
`Set<ORecordId>`	`recordsChangedRecently(int maxEntries)` This method finds all the records changed in the last X transactions.
`OStorageOperationResult<Integer>`	`recyclePosition(ORecordId rid, byte[] content, int version, byte recordType)` Resurrects a record that was previously deleted, with a new content.
`void`	`registerRecoverListener(OStorageRecoverListener recoverListener)`
`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`	`releaseReadLock(ORID rid)`
`void`	`releaseWriteLock(ORID rid)`
`void`	`reload()`
`boolean`	`removeKeyFromIndex(int indexId, Object key)`
`void`	`removeProperty(String property)`
`boolean`	`removeRidIndexEntry(int indexId, Object key, ORID value)`
`void`	`renameCluster(String oldName, String newName)` Method that completes the cluster rename operation.
`void`	`requestCheckpoint()`
`protected boolean`	`restoreAtomicUnit(List<OWALRecord> atomicUnit, OModifiableBoolean atLeastOnePageUpdate)`
`protected OLogSequenceNumber`	`restoreFrom(OLogSequenceNumber lsn, OWriteAheadLog writeAheadLog)`
`void`	`restoreFromIncrementalBackup(String filePath)`
`void`	`restoreFullIncrementalBackup(InputStream stream)`
`void`	`rollback(OMicroTransaction microTransaction)` Rollbacks the given micro-transaction.
`void`	`rollback(OTransactionInternal clientTx)`
`protected void`	`serializeDeltaContent(OutputStream stream, OCommandOutputListener outputListener, SortedSet<ORID> sortedRids, OLogSequenceNumber lsn)`
`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)`
`boolean`	`setClusterStatus(OAtomicOperation atomicOperation, OCluster cluster, OStorageClusterConfiguration.STATUS status)` INTERNAL METHOD !!!
`void`	`setConflictStrategy(ORecordConflictStrategy conflictResolver)`
`void`	`setDateFormat(String dateFormat)`
`void`	`setDateTimeFormat(String dateTimeFormat)`
`void`	`setDefaultClusterId(int defaultClusterId)`
`void`	`setIndexMgrRecordId(String indexMgrRecordId)`
`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`	`setStorageConfigurationUpdateListener(OStorageConfigurationUpdateListener storageConfigurationUpdateListener)`
`void`	`setTimeZone(TimeZone timeZoneValue)`
`void`	`setValidation(boolean validation)`
`void`	`startGatheringPerformanceStatisticForCurrentThread()` Starts to gather information about storage performance for current thread.
`boolean`	`supportIncremental()`
`void`	`synch()`
`void`	`truncateCluster(String clusterName)`
`void`	`tryToDeleteTreeRidBag(OSBTreeRidBag ridBag)`
`void`	`underDistributedStorage()` This method is called by distributed storage during initialization to indicate that database is used in distributed cluster configuration
`void`	`unregisterRecoverListener(OStorageRecoverListener recoverListener)`
`void`	`updateIndexEntry(int indexId, Object key, OIndexKeyUpdater<Object> valueCreator)`
`OStorageOperationResult<Integer>`	`updateRecord(ORecordId rid, boolean updateContent, byte[] content, int version, byte recordType, int mode, ORecordCallback<Integer> callback)`
`boolean`	`validatedPutIndexValue(int indexId, Object key, ORID value, OBaseIndexEngine.Validator<Object,ORID> validator)` Puts the given value under the given key into this storage for the index with the given index id.
`boolean`	`wereDataRestoredAfterOpen()`
`boolean`	`wereNonTxOperationsPerformedInPreviousOpen()`

Methods inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract
close, dropCluster, existsResource, getComponentsFactory, getName, getResource, getStatus, getUnderlying, getURL, getVersion, isAssigningClusterIds, isDistributed, normalizeName, removeResource, shutdown, toString

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.OStorage
close, dropCluster, exists, getComponentsFactory, getName, getStatus, getType, getUnderlying, getURL, getVersion, isAssigningClusterIds, isDistributed, shutdown

Methods inherited from interface com.orientechnologies.orient.core.util.OBackupable
backup, restore

Methods inherited from interface com.orientechnologies.common.concur.resource.OSharedContainer
existsResource, getResource, removeResource

Field Detail

fuzzyCheckpointExecutor

protected static final OScheduledThreadPoolExecutorWithLogging fuzzyCheckpointExecutor

interruptionManager

protected OStorageInterruptionManager interruptionManager

sbTreeCollectionManager

protected final OSBTreeCollectionManagerShared sbTreeCollectionManager

writeAheadLog

protected volatile OWriteAheadLog writeAheadLog

readCache

protected volatile OReadCache readCache

writeCache

protected volatile OWriteCache writeCache

atomicOperationsManager

protected volatile OAtomicOperationsManager atomicOperationsManager

DATABASE_INSTANCE_ID

protected static final String DATABASE_INSTANCE_ID

See Also:: Constant Field Values

atomicOperationsTable

protected AtomicOperationsTable atomicOperationsTable

Constructor Detail

OAbstractPaginatedStorage

public OAbstractPaginatedStorage(String name,
                                 String filePath,
                                 String mode,
                                 int id)

Method Detail

open

public final void open(String iUserName,
                       String iUserPassword,
                       OContextConfiguration contextConfiguration)

Specified by:: open in interface OStorage

open

public final void open(OContextConfiguration contextConfiguration)

handleJVMError
```
public final void handleJVMError(Error e)
```
That is internal method which is called once we encounter any error inside of JVM. In such case we need to restart JVM to avoid any data corruption. Till JVM is not restarted storage will be put in read-only state.

underDistributedStorage
```
public void underDistributedStorage()
```
This method is called by distributed storage during initialization to indicate that database is used in distributed cluster configuration

getCreatedAtVersion
```
public final String getCreatedAtVersion()
```
Specified by:

getCreatedAtVersion in interface OStorage

Returns:

Version of product release under which storage was created.

openIndexes
```
protected final void openIndexes()
```

openClusters

protected final void openClusters()
                           throws IOException

Throws:: IOException

open

public void open(OToken iToken,
                 OContextConfiguration configuration)

create

public void create(OContextConfiguration contextConfiguration)

Specified by:: create in interface OStorage

generateDatabaseInstanceId

protected void generateDatabaseInstanceId(OAtomicOperation atomicOperation)

readDatabaseInstanceId

protected UUID readDatabaseInstanceId()

checkDatabaseInstanceId

protected void checkDatabaseInstanceId(UUID backupUUID)

isClosed
```
public final boolean isClosed()
```
Specified by:

isClosed in interface OStorage

Overrides:

isClosed in class OStorageAbstract

close

public final void close(boolean force,
                        boolean onDelete)

Specified by:: close in interface OStorage
Overrides:: close in class OStorageAbstract

delete
```
public final void delete()
```
Specified by:

delete in interface OStorage

check

public boolean check(boolean verbose,
                     OCommandOutputListener listener)

addCluster
```
public final int addCluster(String clusterName,
                            Object... parameters)
```
Description copied from interface: OStorage

Add a new cluster into the storage.

Specified by:

addCluster in interface OStorage

Parameters:

clusterName - name of the cluster

addCluster
```
public final int addCluster(String clusterName,
                            int requestedId,
                            Object... parameters)
```
Description copied from interface: OStorage

Add a new cluster into the storage.

Specified by:

addCluster in interface OStorage

Parameters:

clusterName - name of the cluster

requestedId - requested id of the cluster

dropCluster
```
public final boolean dropCluster(int clusterId,
                                 boolean iTruncate)
```
Description copied from interface: OStorage

Drops a cluster.

Specified by:

dropCluster in interface OStorage

Parameters:

clusterId - 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

isSystemCluster
```
public boolean isSystemCluster(int clusterId)
```
Specified by:

isSystemCluster in interface OStorage

getLastClusterPosition
```
public long getLastClusterPosition(int clusterId)
```
Specified by:

getLastClusterPosition 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

truncateCluster
```
public void truncateCluster(String clusterName)
```
Specified by:

truncateCluster in interface OStorage

countRecords
```
public long countRecords()
```
Description copied from interface: OStorage

Returns the total number of records.

Specified by:

countRecords in interface OStorage

Specified by:

countRecords in class OStorageAbstract

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

getId
```
public final int getId()
```
Specified by:

getId in interface OIdentifiableStorage

setClusterStatus

public final boolean setClusterStatus(OAtomicOperation atomicOperation,
                                      OCluster cluster,
                                      OStorageClusterConfiguration.STATUS status)
                               throws IOException

INTERNAL METHOD !!!

Throws:: IOException

getSBtreeCollectionManager
```
public final OSBTreeCollectionManager getSBtreeCollectionManager()
```
Specified by:

getSBtreeCollectionManager in interface OStorage

getReadCache
```
public OReadCache getReadCache()
```

getWriteCache
```
public OWriteCache getWriteCache()
```

count
```
public final long count(int iClusterId)
```
Specified by:

count in interface OStorage

count

public final long count(int clusterId,
                        boolean countTombstones)

Specified by:: count in interface OStorage

getClusterDataRange
```
public final long[] getClusterDataRange(int iClusterId)
```
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:

iClusterId - Cluster id

getLSN
```
public OLogSequenceNumber getLSN()
```

count

public final long count(int[] iClusterIds)

Specified by:: count in interface OStorage

onException
```
public final void onException(Throwable e)
```
Specified by:

onException in interface OBackgroundExceptionListener

recordsChangedAfterLSN
```
public OBackgroundDelta recordsChangedAfterLSN(OLogSequenceNumber lsn,
                                               OCommandOutputListener outputListener)
```
This method finds all the records which were updated starting from (but not including) current LSN and write result in provided output stream. In output stream will be included all thw records which were updated/deleted/created since passed in LSN till the current moment. Deleted records are written in output stream first, then created/updated records. All records are sorted by record id. Data format:
1. Amount of records (single entry) - 8 bytes
2. Record's cluster id - 4 bytes
3. Record's cluster position - 8 bytes
4. Delete flag, 1 if record is deleted - 1 byte
5. Record version , only if record is not deleted - 4 bytes
6. Record type, only if record is not deleted - 1 byte
7. Length of binary presentation of record, only if record is not deleted - 4 bytes
8. Binary presentation of the record, only if record is not deleted - length of content is provided in above entity
Parameters:

lsn - LSN from which we should find changed records

Returns:

Last LSN processed during examination of changed records, or null if it was impossible to find changed records: write ahead log is absent, record with start LSN was not found in WAL, etc.

See Also:

OGlobalConfiguration.STORAGE_TRACK_CHANGED_RECORDS_IN_WAL

serializeDeltaContent

protected void serializeDeltaContent(OutputStream stream,
                                     OCommandOutputListener outputListener,
                                     SortedSet<ORID> sortedRids,
                                     OLogSequenceNumber lsn)

recordsChangedRecently
```
public Set<ORecordId> recordsChangedRecently(int maxEntries)
```
This method finds all the records changed in the last X transactions.

Parameters:

maxEntries - Maximum number of entries to check back from last log.

Returns:

A set of record ids of the changed records

See Also:

OGlobalConfiguration.STORAGE_TRACK_CHANGED_RECORDS_IN_WAL

count

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

Specified by:: count in interface OStorage

createRecord

public final OStorageOperationResult<OPhysicalPosition> createRecord(ORecordId rid,
                                                                     byte[] content,
                                                                     int recordVersion,
                                                                     byte recordType,
                                                                     int mode,
                                                                     ORecordCallback<Long> callback)

Specified by:: createRecord in interface OStorage

getRecordMetadata
```
public final ORecordMetadata getRecordMetadata(ORID rid)
```
Specified by:

getRecordMetadata in interface OStorage

isDeleted
```
public boolean isDeleted(ORID rid)
```

browseCluster

public Iterator<OClusterBrowsePage> browseCluster(int clusterId)

readRecord

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

Specified by:: readRecord in interface OStorage

readRecordIfVersionIsNotLatest

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

Specified by:: readRecordIfVersionIsNotLatest in interface OStorage
Throws:: ORecordNotFoundException

updateRecord

public final OStorageOperationResult<Integer> updateRecord(ORecordId rid,
                                                           boolean updateContent,
                                                           byte[] content,
                                                           int version,
                                                           byte recordType,
                                                           int mode,
                                                           ORecordCallback<Integer> callback)

recyclePosition

public final OStorageOperationResult<Integer> recyclePosition(ORecordId rid,
                                                              byte[] content,
                                                              int version,
                                                              byte recordType)

Description copied from interface: OStorage

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

Specified by:: recyclePosition in interface OStorage

getStorageTransaction

public OStorageTransaction getStorageTransaction()

getAtomicOperationsManager

public final OAtomicOperationsManager getAtomicOperationsManager()

getWALInstance

public OWriteAheadLog getWALInstance()

getIdGen

public AtomicOperationIdGen getIdGen()

deleteRecord

public final OStorageOperationResult<Boolean> deleteRecord(ORecordId rid,
                                                           int version,
                                                           int mode,
                                                           ORecordCallback<Boolean> callback)

Specified by:: deleteRecord in interface OStorage

hideRecord

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

Specified by:: hideRecord in interface OStorage

getPerformanceStatisticManager

protected OPerformanceStatisticManager getPerformanceStatisticManager()

startGatheringPerformanceStatisticForCurrentThread
```
public void startGatheringPerformanceStatisticForCurrentThread()
```
Starts to gather information about storage performance for current thread. Details which performance characteristics are gathered can be found at OSessionStoragePerformanceStatistic.

See Also:

completeGatheringPerformanceStatisticForCurrentThread()

completeGatheringPerformanceStatisticForCurrentThread
```
public OSessionStoragePerformanceStatistic completeGatheringPerformanceStatisticForCurrentThread()
```
Completes gathering performance characteristics for current thread initiated by call of startGatheringPerformanceStatisticForCurrentThread()

Returns:

Performance statistic gathered after call of startGatheringPerformanceStatisticForCurrentThread() or null if profiling of storage was not started.

getClusterNames
```
public final Set<String> getClusterNames()
```
Specified by:

getClusterNames in interface OStorage

getClusterIdByName
```
public final int getClusterIdByName(String clusterName)
```
Specified by:

getClusterIdByName in interface OStorage

preallocateRids
```
public void preallocateRids(OTransactionInternal clientTx)
```
Scan the given transaction for new record and allocate a record id for them, the relative record id is inserted inside the transaction for future use.

Parameters:

clientTx - the transaction of witch allocate rids

commit
```
public List<ORecordOperation> commit(OTransactionInternal clientTx)
```
Traditional commit that support already temporary rid and already assigned rids

Specified by:

commit in interface OStorage

Parameters:

clientTx - the transaction to commit

Returns:

The list of operations applied by the transaction

commitPreAllocated
```
public List<ORecordOperation> commitPreAllocated(OTransactionInternal clientTx)
```
Commit a transaction where the rid where pre-allocated in a previous phase

Parameters:

clientTx - the pre-allocated transaction to commit

Returns:

The list of operations applied by the transaction

commit
```
protected List<ORecordOperation> commit(OTransactionInternal transaction,
                                        boolean allocated)
```
The commit operation can be run in 3 different conditions, embedded commit, pre-allocated commit, other node commit. Embedded commit is the basic commit where the operation is run in embedded or server side, the transaction arrive with invalid rids that get allocated and committed. pre-allocated commit is the commit that happen after an preAllocateRids call is done, this is usually run by the coordinator of a tx in distributed. other node commit is the commit that happen when a node execute a transaction of another node where all the rids are already allocated in the other node.

Parameters:

transaction - the transaction to commit

allocated - true if the operation is pre-allocated commit

Returns:

The list of operations applied by the transaction

loadIndexEngine

public int loadIndexEngine(String name)

loadExternalIndexEngine

public int loadExternalIndexEngine(String engineName,
                                   String algorithm,
                                   String indexType,
                                   OIndexDefinition indexDefinition,
                                   OBinarySerializer<?> valueSerializer,
                                   boolean isAutomatic,
                                   Boolean durableInNonTxMode,
                                   int version,
                                   int apiVersion,
                                   boolean multivalue,
                                   Map<String,String> engineProperties)

addIndexEngine

public int addIndexEngine(String engineName,
                          String algorithm,
                          String indexType,
                          OIndexDefinition indexDefinition,
                          OBinarySerializer<?> valueSerializer,
                          boolean isAutomatic,
                          Boolean durableInNonTxMode,
                          int version,
                          int apiVersion,
                          boolean multivalue,
                          Map<String,String> engineProperties,
                          Set<String> clustersToIndex,
                          ODocument metadata)

extractEngineAPIVersion

public static int extractEngineAPIVersion(int externalId)

deleteIndexEngine

public void deleteIndexEngine(int indexId)
                       throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

indexContainsKey

public boolean indexContainsKey(int indexId,
                                Object key)
                         throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

removeKeyFromIndex

public boolean removeKeyFromIndex(int indexId,
                                  Object key)
                           throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

clearIndex

public void clearIndex(int indexId)
                throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexValue

public Object getIndexValue(int indexId,
                            Object key)
                     throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexEngine

public OBaseIndexEngine getIndexEngine(int indexId)
                                throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

updateIndexEntry

public void updateIndexEntry(int indexId,
                             Object key,
                             OIndexKeyUpdater<Object> valueCreator)
                      throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

callIndexEngine

public <T> T callIndexEngine(boolean atomicOperation,
                             boolean readOperation,
                             int indexId,
                             OIndexEngineCallback<T> callback)
                      throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

putRidIndexEntry

public void putRidIndexEntry(int indexId,
                             Object key,
                             ORID value)
                      throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

removeRidIndexEntry

public boolean removeRidIndexEntry(int indexId,
                                   Object key,
                                   ORID value)
                            throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

putIndexValue

public void putIndexValue(int indexId,
                          Object key,
                          Object value)
                   throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

validatedPutIndexValue
```
public boolean validatedPutIndexValue(int indexId,
                                      Object key,
                                      ORID value,
                                      OBaseIndexEngine.Validator<Object,ORID> validator)
                               throws OInvalidIndexEngineIdException
```
Puts the given value under the given key into this storage for the index with the given index id. Validates the operation using the provided validator.

Parameters:

indexId - the index id of the index to put the value into.

key - the key to put the value under.

value - the value to put.

validator - the operation validator.

Returns:

true if the validator allowed the put, false otherwise.

Throws:

OInvalidIndexEngineIdException

See Also:

OBaseIndexEngine.Validator#validate(Object, Object, Object)

getIndexFirstKey

public Object getIndexFirstKey(int indexId)
                        throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexLastKey

public Object getIndexLastKey(int indexId)
                       throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

iterateIndexEntriesBetween

public OIndexCursor iterateIndexEntriesBetween(int indexId,
                                               Object rangeFrom,
                                               boolean fromInclusive,
                                               Object rangeTo,
                                               boolean toInclusive,
                                               boolean ascSortOrder,
                                               OBaseIndexEngine.ValuesTransformer transformer)
                                        throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

iterateIndexEntriesMajor

public OIndexCursor iterateIndexEntriesMajor(int indexId,
                                             Object fromKey,
                                             boolean isInclusive,
                                             boolean ascSortOrder,
                                             OBaseIndexEngine.ValuesTransformer transformer)
                                      throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

iterateIndexEntriesMinor

public OIndexCursor iterateIndexEntriesMinor(int indexId,
                                             Object toKey,
                                             boolean isInclusive,
                                             boolean ascSortOrder,
                                             OBaseIndexEngine.ValuesTransformer transformer)
                                      throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexCursor

public OIndexCursor getIndexCursor(int indexId,
                                   OBaseIndexEngine.ValuesTransformer valuesTransformer)
                            throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexDescCursor

public OIndexCursor getIndexDescCursor(int indexId,
                                       OBaseIndexEngine.ValuesTransformer valuesTransformer)
                                throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexKeyCursor

public OIndexKeyCursor getIndexKeyCursor(int indexId)
                                  throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

getIndexSize

public long getIndexSize(int indexId,
                         OBaseIndexEngine.ValuesTransformer transformer)
                  throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

hasIndexRangeQuerySupport

public boolean hasIndexRangeQuerySupport(int indexId)
                                  throws OInvalidIndexEngineIdException

Throws:: OInvalidIndexEngineIdException

rollback

public void rollback(OTransactionInternal clientTx)

Specified by:: rollback in interface OStorage

rollback
```
public void rollback(OMicroTransaction microTransaction)
```
Rollbacks the given micro-transaction.

Parameters:

microTransaction - the micro-transaction to rollback.

checkForRecordValidity
```
public final boolean checkForRecordValidity(OPhysicalPosition ppos)
```
Specified by:

checkForRecordValidity in interface OStorage

Overrides:

checkForRecordValidity in class OStorageAbstract

synch
```
public final void synch()
```
Specified by:

synch in interface OStorage

getPhysicalClusterNameById
```
public final String getPhysicalClusterNameById(int iClusterId)
```
Specified by:

getPhysicalClusterNameById in interface OStorage

getDefaultClusterId
```
public final int getDefaultClusterId()
```
Specified by:

getDefaultClusterId in interface OStorage

setDefaultClusterId
```
public final void setDefaultClusterId(int defaultClusterId)
```
Specified by:

setDefaultClusterId in interface OStorage

getSize
```
public final long getSize()
```
Description copied from interface: OStorage

Returns the size of the database.

Specified by:

getSize in interface OStorage

getClusters
```
public final int getClusters()
```
Specified by:

getClusters in interface OStorage

renameCluster
```
public final void renameCluster(String oldName,
                                String newName)
```
Method that completes the cluster rename operation. IT WILL NOT RENAME A CLUSTER, IT JUST CHANGES THE NAME IN THE INTERNAL MAPPING

cleanOutRecord

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

Specified by:: cleanOutRecord in interface OStorage

freeze
```
public final 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 final 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

isRemote
```
public final boolean isRemote()
```
Specified by:

isRemote in interface OStorage

wereDataRestoredAfterOpen

public boolean wereDataRestoredAfterOpen()

wereNonTxOperationsPerformedInPreviousOpen

public boolean wereNonTxOperationsPerformedInPreviousOpen()

reload
```
public final void reload()
```
Specified by:

reload in interface OStorage

getMode
```
public String getMode()
```

lowDiskSpace

public final void lowDiskSpace(OLowDiskSpaceInformation information)

Specified by:: lowDiskSpace in interface OLowDiskSpaceListener

pageIsBroken
```
public final void pageIsBroken(String fileName,
                               long pageIndex)
```
Description copied from interface: OPageIsBrokenListener

Method is called by write cache when it is detected that data page in file is broken.

Specified by:

pageIsBroken in interface OPageIsBrokenListener

Parameters:

fileName - Name of broken file.

pageIndex - Index of page which is broken in file.

requestCheckpoint
```
public final void requestCheckpoint()
```
Specified by:

requestCheckpoint in interface OCheckpointRequestListener

command
```
public final Object command(OCommandRequestText iCommand)
```
Executes the command request and return the result back.

Specified by:

command in interface OStorage

executeCommand

public final Object executeCommand(OCommandRequestText iCommand,
                                   OCommandExecutor executor)

higherPhysicalPositions

public final OPhysicalPosition[] higherPhysicalPositions(int currentClusterId,
                                                         OPhysicalPosition physicalPosition)

Specified by:: higherPhysicalPositions in interface OStorage

ceilingPhysicalPositions

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

Specified by:: ceilingPhysicalPositions in interface OStorage

lowerPhysicalPositions

public final OPhysicalPosition[] lowerPhysicalPositions(int currentClusterId,
                                                        OPhysicalPosition physicalPosition)

Specified by:: lowerPhysicalPositions in interface OStorage

floorPhysicalPositions

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

Specified by:: floorPhysicalPositions in interface OStorage

acquireWriteLock

public final void acquireWriteLock(ORID rid)

releaseWriteLock

public final void releaseWriteLock(ORID rid)

acquireReadLock

public final void acquireReadLock(ORID rid)

releaseReadLock

public final void releaseReadLock(ORID rid)

getClusterRecordConflictStrategy
```
public final ORecordConflictStrategy getClusterRecordConflictStrategy()
```
Specified by:

getClusterRecordConflictStrategy in interface OStorage

setConflictStrategy

public final void setConflictStrategy(ORecordConflictStrategy conflictResolver)

Specified by:: setConflictStrategy in interface OStorage

getRecordScanned
```
public AtomicLong getRecordScanned()
```

copyWALToIncrementalBackup

protected abstract OLogSequenceNumber copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
                                                                 long startSegment)
                                                          throws IOException

Throws:: IOException

isWriteAllowedDuringIncrementalBackup

protected abstract boolean isWriteAllowedDuringIncrementalBackup()

getRecoverListener

public OStorageRecoverListener getRecoverListener()

registerRecoverListener

public void registerRecoverListener(OStorageRecoverListener recoverListener)

unregisterRecoverListener

public void unregisterRecoverListener(OStorageRecoverListener recoverListener)

createWalTempDirectory

protected abstract File createWalTempDirectory()

addFileToDirectory

protected abstract void addFileToDirectory(String name,
                                           InputStream stream,
                                           File directory)
                                    throws IOException

Throws:: IOException

createWalFromIBUFiles

protected abstract OWriteAheadLog createWalFromIBUFiles(File directory,
                                                        OContextConfiguration contextConfiguration,
                                                        Locale locale)
                                                 throws IOException

Throws:: IOException

checkOpenness
```
protected final void checkOpenness()
```
Checks if the storage is open. If it's closed an exception is raised.

makeFuzzyCheckpoint

protected final void makeFuzzyCheckpoint()

tryToDeleteTreeRidBag

public void tryToDeleteTreeRidBag(OSBTreeRidBag ridBag)

makeFullCheckpoint
```
protected void makeFullCheckpoint()
```

getFullCheckpointCount
```
public long getFullCheckpointCount()
```

checkIfStorageDirty

protected long checkIfStorageDirty()
                            throws IOException

Throws:: IOException

initConfiguration

protected void initConfiguration(OAtomicOperation atomicOperation,
                                 OContextConfiguration contextConfiguration)
                          throws IOException

Throws:: IOException

postCreateSteps

protected final void postCreateSteps()

preCreateSteps

protected void preCreateSteps()
                       throws IOException

Throws:: IOException

initWalAndDiskCache

protected abstract void initWalAndDiskCache(OContextConfiguration contextConfiguration)
                                     throws IOException,
                                            InterruptedException

Throws:: IOException; InterruptedException

postCloseSteps

protected abstract void postCloseSteps(boolean onDelete,
                                       boolean jvmError,
                                       long lastTxId)
                                throws IOException

Throws:: IOException

postCloseStepsAfterLock

protected void postCloseStepsAfterLock(Map<String,Object> params)

preCloseSteps

protected Map<String,Object> preCloseSteps()

postDeleteSteps
```
protected void postDeleteSteps()
```

makeStorageDirty

protected void makeStorageDirty()
                         throws IOException

Throws:: IOException

clearStorageDirty

protected void clearStorageDirty()
                          throws IOException

Throws:: IOException

isDirty
```
protected boolean isDirty()
```

closeClusters

protected void closeClusters(boolean onDelete)
                      throws IOException

Throws:: IOException

closeIndexes

protected void closeIndexes(boolean onDelete)
                     throws IOException

Throws:: IOException

incrementalBackup

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

Specified by:: incrementalBackup in interface OStorage
Returns:: Backup file name
Throws:: UnsupportedOperationException

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

restoreFromIncrementalBackup
```
public void restoreFromIncrementalBackup(String filePath)
```
Specified by:

restoreFromIncrementalBackup in interface OStorage

restoreFullIncrementalBackup

public void restoreFullIncrementalBackup(InputStream stream)
                                  throws UnsupportedOperationException

Specified by:: restoreFullIncrementalBackup in interface OStorage
Throws:: UnsupportedOperationException

restoreFrom

protected final OLogSequenceNumber restoreFrom(OLogSequenceNumber lsn,
                                               OWriteAheadLog writeAheadLog)
                                        throws IOException

Throws:: IOException

restoreAtomicUnit

protected final boolean restoreAtomicUnit(List<OWALRecord> atomicUnit,
                                          OModifiableBoolean atLeastOnePageUpdate)
                                   throws IOException

Throws:: IOException

checkReadOnlyConditions

public final void checkReadOnlyConditions()

setStorageConfigurationUpdateListener

public void setStorageConfigurationUpdateListener(OStorageConfigurationUpdateListener storageConfigurationUpdateListener)

pauseConfigurationUpdateNotifications

public void pauseConfigurationUpdateNotifications()

fireConfigurationUpdateNotifications

public void fireConfigurationUpdateNotifications()

getRidsGroupedByCluster

protected static Map<Integer,List<ORecordId>> getRidsGroupedByCluster(Collection<ORecordId> rids)

logAndPrepareForRethrow

protected final RuntimeException logAndPrepareForRethrow(RuntimeException runtimeException)

logAndPrepareForRethrow

protected final Error logAndPrepareForRethrow(Error error)

logAndPrepareForRethrow

protected final RuntimeException logAndPrepareForRethrow(Throwable throwable)

getConfiguration
```
public final OStorageConfiguration getConfiguration()
```
Specified by:

getConfiguration in interface OStorage

Overrides:

getConfiguration in class OStorageAbstract

setSchemaRecordId
```
public final void setSchemaRecordId(String schemaRecordId)
```
Specified by:

setSchemaRecordId in interface OStorage

setDateFormat
```
public final void setDateFormat(String dateFormat)
```
Specified by:

setDateFormat in interface OStorage

setTimeZone

public final void setTimeZone(TimeZone timeZoneValue)

Specified by:: setTimeZone in interface OStorage

setLocaleLanguage
```
public final void setLocaleLanguage(String locale)
```
Specified by:

setLocaleLanguage in interface OStorage

setCharset
```
public final void setCharset(String charset)
```
Specified by:

setCharset in interface OStorage

setIndexMgrRecordId
```
public final void setIndexMgrRecordId(String indexMgrRecordId)
```
Specified by:

setIndexMgrRecordId in interface OStorage

setDateTimeFormat
```
public final void setDateTimeFormat(String dateTimeFormat)
```
Specified by:

setDateTimeFormat in interface OStorage

setLocaleCountry
```
public final void setLocaleCountry(String localeCountry)
```
Specified by:

setLocaleCountry in interface OStorage

setClusterSelection
```
public final void setClusterSelection(String clusterSelection)
```
Specified by:

setClusterSelection in interface OStorage

setMinimumClusters
```
public final void setMinimumClusters(int minimumClusters)
```
Specified by:

setMinimumClusters in interface OStorage

setValidation
```
public final void setValidation(boolean validation)
```
Specified by:

setValidation in interface OStorage

removeProperty
```
public final void removeProperty(String property)
```
Specified by:

removeProperty in interface OStorage

setProperty

public final void setProperty(String property,
                              String value)

Specified by:: setProperty in interface OStorage

setRecordSerializer

public final void setRecordSerializer(String recordSerializer,
                                      int version)

Specified by:: setRecordSerializer in interface OStorage

clearProperties
```
public final void clearProperties()
```
Specified by:

clearProperties in interface OStorage

incOnOpen
```
public void incOnOpen()
```

getSessionCount
```
public int getSessionCount()
```

getLastCloseTime
```
public long getLastCloseTime()
```

interruptExecution
```
public void interruptExecution(Thread thread)
```
forces interruption of this execution

Parameters:

thread - The thread where this storage instance is running (has to be provided from higher level)

Class OAbstractPaginatedStorage

Nested Class Summary

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

Field Summary

Fields inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract

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

Constructor Summary

Method Summary

Methods inherited from class com.orientechnologies.orient.core.storage.OStorageAbstract

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.util.OBackupable

Methods inherited from interface com.orientechnologies.common.concur.resource.OSharedContainer

Field Detail

fuzzyCheckpointExecutor

interruptionManager

sbTreeCollectionManager

writeAheadLog

readCache

writeCache

atomicOperationsManager

DATABASE_INSTANCE_ID

atomicOperationsTable

Constructor Detail

OAbstractPaginatedStorage

Method Detail

open

open

handleJVMError

underDistributedStorage

getCreatedAtVersion

openIndexes

openClusters

open

create

generateDatabaseInstanceId

readDatabaseInstanceId

checkDatabaseInstanceId

isClosed

close

delete

check

addCluster

addCluster

dropCluster

getClusterNameById

getClusterRecordsSizeById

getClusterRecordsSizeByName

isSystemCluster

getLastClusterPosition

setClusterAttribute

setClusterAttribute

getClusterRecordConflictStrategy

getClusterEncryption

truncateCluster

countRecords

getClusterNextPosition

getRecordStatus

getId

setClusterStatus

getSBtreeCollectionManager

getReadCache

getWriteCache

count

count

getClusterDataRange

getLSN

count

onException

recordsChangedAfterLSN

serializeDeltaContent

recordsChangedRecently

count

createRecord

getRecordMetadata

isDeleted

browseCluster

readRecord

readRecordIfVersionIsNotLatest

updateRecord