com.orientechnologies.orient.core.storage.memory
Class ODirectMemoryStorage
public class ODirectMemoryStorage extends OAbstractPaginatedStorage
OAbstractPaginatedStorage.StartupMetadataOStorage.LOCKING_STRATEGY, OStorage.STATUSatomicOperationsManager, atomicOperationsTable, DATABASE_INSTANCE_ID, fuzzyCheckpointExecutor, readCache, sbTreeCollectionManager, writeAheadLog, writeCachecomponentsFactory, configuration, error, errorLock, inError, mode, name, sharedContainer, stateLock, status, storageThreadGroup, urlCLUSTER_DEFAULT_NAME| Constructor and Description |
|---|
ODirectMemoryStorage(String name,
String filePath,
String mode,
int id) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addFileToDirectory(String name,
InputStream stream,
File directory) |
List<String> |
backup(OutputStream out,
Map<String,Object> options,
Callable<Object> callable,
OCommandOutputListener iListener,
int compressionLevel,
int bufferSize)
Executes a backup of the database.
|
protected OLogSequenceNumber |
copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
long startSegment) |
protected OWriteAheadLog |
createWalFromIBUFiles(File directory,
OContextConfiguration contextConfiguration,
Locale locale,
byte[] iv) |
protected File |
createWalTempDirectory() |
boolean |
exists() |
void |
flushAllData() |
protected byte[] |
getIv() |
String |
getType()
Returns the storage's type.
|
String |
getURL() |
protected void |
initIv() |
protected void |
initWalAndDiskCache(OContextConfiguration contextConfiguration) |
protected boolean |
isWriteAllowedDuringIncrementalBackup() |
protected void |
postCloseSteps(boolean onDelete,
boolean internalError,
long lastTxId) |
protected void |
readIv() |
void |
restore(InputStream in,
Map<String,Object> options,
Callable<Object> callable,
OCommandOutputListener iListener)
Executes a restore of a database backup.
|
void |
shutdown()
This method is called in
Orient.shutdown() method. |
acquireIndexEngineExclusiveLock, acquireReadLock, acquireReadLock, acquireWriteLock, acquireWriteLock, addCluster, addCluster, addIndexEngine, browseCluster, callIndexEngine, ceilingPhysicalPositions, check, checkDatabaseInstanceId, checkErrorState, checkForRecordValidity, checkIfStorageDirty, checkOpenness, cleanOutRecord, clearIndex, clearProperties, clearStorageDirty, close, closeClusters, closeIndexes, command, commit, commit, commitPreAllocated, count, count, count, count, create, createRecord, delete, deleteIndexEngine, deleteRecord, dropCluster, executeCommand, extractEngineAPIVersion, extractTransactionsFromWal, fireConfigurationUpdateNotifications, floorPhysicalPositions, freeze, fullIncrementalBackup, generateDatabaseInstanceId, getAtomicOperationsManager, getClusterDataRange, getClusterEncryption, getClusterIdByName, getClusterInstances, getClusterName, getClusterNameById, getClusterNames, getClusterNextPosition, getClusterRecordConflictStrategy, getClusterRecordsSizeById, getClusterRecordsSizeByName, getClusters, getConfiguration, getCreatedAtVersion, getDefaultClusterId, getId, getIdGen, getIndexDescStream, getIndexKeyStream, getIndexNameByKey, getIndexSize, getIndexStream, getIndexValue, getIndexValues, getLastCloseTime, getLastClusterPosition, getLastMetadata, getLSN, getMode, getOpenedAtVersion, getPhysicalClusterNameById, getReadCache, getRecordConflictStrategy, getRecordMetadata, getRecordScanned, getRecordStatus, getRecoverListener, getRidsGroupedByCluster, getSBtreeCollectionManager, getSessionCount, getSize, getStorageTransaction, getUuid, getWALInstance, getWriteCache, hasIndexRangeQuerySupport, higherPhysicalPositions, incOnOpen, incrementalBackup, initConfiguration, isClosed, isDeleted, isDirty, isInError, isRemote, isSystemCluster, iterateIndexEntriesBetween, iterateIndexEntriesMajor, iterateIndexEntriesMinor, loadExternalIndexEngine, loadIndexEngine, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, lowerPhysicalPositions, makeFuzzyCheckpoint, makeStorageDirty, metadataOnly, moveToErrorStateIfNeeded, onException, open, open, open, openClusters, openIndexes, pageIsBroken, pauseConfigurationUpdateNotifications, postCloseStepsAfterLock, postCreateSteps, postDeleteSteps, preallocateRids, preCloseSteps, preCreateSteps, putIndexValue, putRidIndexEntry, readDatabaseInstanceId, readRecord, readRecordIfVersionIsNotLatest, registerRecoverListener, release, releaseReadLock, releaseWriteLock, reload, removeKeyFromIndex, removeProperty, removeRidIndexEntry, requestCheckpoint, restoreAtomicUnit, restoreFrom, restoreFromIncrementalBackup, restoreFullIncrementalBackup, serializeDeltaContent, setCharset, setClusterAttribute, setClusterAttribute, setClusterSelection, setConflictStrategy, setDateFormat, setDateTimeFormat, setDefaultClusterId, setIndexMgrRecordId, setLocaleCountry, setLocaleLanguage, setMinimumClusters, setProperty, setRecordSerializer, setSchemaRecordId, setStorageConfigurationUpdateListener, setTimeZone, setValidation, supportIncremental, synch, tryToDeleteTreeRidBag, unregisterRecoverListener, updateIndexEntry, updateRecord, validatedPutIndexValue, wereDataRestoredAfterOpen, wereNonTxOperationsPerformedInPreviousOpenclose, countRecords, dropCluster, existsResource, getComponentsFactory, getName, getResource, getStatus, getUnderlying, getVersion, isAssigningClusterIds, isDistributed, normalizeName, removeResource, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitclose, countRecords, dropCluster, getComponentsFactory, getName, getStatus, getUnderlying, getVersion, isAssigningClusterIds, isDistributedexistsResource, getResource, removeResourceprotected void initWalAndDiskCache(OContextConfiguration contextConfiguration)
initWalAndDiskCache in class OAbstractPaginatedStorageprotected void postCloseSteps(boolean onDelete,
boolean internalError,
long lastTxId)
postCloseSteps in class OAbstractPaginatedStoragepublic boolean exists()
public String getType()
OStoragepublic String getURL()
getURL in interface OStorageInfogetURL in class OStorageAbstractpublic void flushAllData()
flushAllData in class OAbstractPaginatedStorageprotected void readIv()
readIv in class OAbstractPaginatedStorageprotected byte[] getIv()
getIv in class OAbstractPaginatedStorageprotected void initIv()
initIv in class OAbstractPaginatedStoragepublic List<String> backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize)
OBackupableout - OutputStream used to write the backup content. Use a FileOutputStream to make the
backup persistent on diskoptions - Backup options as Mapcallable - Callback to execute when the database is lockediListener - Listener called for backup messagescompressionLevel - 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 executebufferSize - Buffer size in bytes, the bigger is the buffer, the more efficient will be
the compressionODatabaseExportpublic void restore(InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener)
OBackupablein - InputStream used to read the backup content. Use a FileInputStream to read a backup
on a diskoptions - Backup options as Mapcallable - Callback to execute when the database is lockediListener - Listener called for backup messagesODatabaseImportprotected OLogSequenceNumber copyWALToIncrementalBackup(ZipOutputStream zipOutputStream, long startSegment)
copyWALToIncrementalBackup in class OAbstractPaginatedStorageprotected boolean isWriteAllowedDuringIncrementalBackup()
isWriteAllowedDuringIncrementalBackup in class OAbstractPaginatedStorageprotected File createWalTempDirectory()
createWalTempDirectory in class OAbstractPaginatedStorageprotected void addFileToDirectory(String name, InputStream stream, File directory)
addFileToDirectory in class OAbstractPaginatedStorageprotected OWriteAheadLog createWalFromIBUFiles(File directory, OContextConfiguration contextConfiguration, Locale locale, byte[] iv)
createWalFromIBUFiles in class OAbstractPaginatedStoragepublic void shutdown()
OStorageOrient.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.shutdown in interface OStorageshutdown in class OStorageAbstractCopyright © 2009–2025 OrientDB. All rights reserved.