one.microstream.storage.types.StorageChannel.Default

All Implemented Interfaces:: Runnable, Unpersistable, StorageActivePart, StorageChannel, StorageChannelResetablePart, StorageHashChannelPart, StorageHousekeepingExecutor

Enclosing interface:: StorageChannel

public static final class StorageChannel.Default
extends Object
implements StorageChannel, Unpersistable, StorageHousekeepingExecutor

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannel
StorageChannel.Default, StorageChannel.EntityCollectorByOid, StorageChannel.EntityCollectorByTid, StorageChannel.HousekeepingTask

Constructor Summary

Constructors
Constructor	Description
`Default(int hashIndex, StorageExceptionHandler exceptionHandler, StorageTaskBroker taskBroker, StorageOperationController operationController, StorageHousekeepingBroker housekeepingBroker, StorageHousekeepingController housekeepingController, StorageEntityCache.Default entityCache, boolean switchByteOrder, BufferSizeProviderIncremental loadingBufferSizeProvider, StorageFileManager.Default fileManager, StorageEventLogger eventLogger)`

Method Summary

Modifier and Type	Method	Description
`int`	`channelIndex()`
`void`	`cleanupStore()`
`ChunksBuffer`	`collectLoadByOids(ChunksBuffer[] resultArray, PersistenceIdSet loadOids)`
`ChunksBuffer`	`collectLoadByTids(ChunksBuffer[] resultArray, PersistenceIdSet loadTids)`
`ChunksBuffer`	`collectLoadRoots(ChunksBuffer[] resultArray)`
`void`	`commitChunkStorage()`
`void`	`commitImportData(long taskTimestamp)`
`StorageRawFileStatistics.ChannelStatistics`	`createRawFileStatistics()`
`void`	`exportData(StorageLiveFileProvider fileProvider)`
`KeyValue<Long,Long>`	`exportTypeEntities(StorageEntityTypeHandler type, AWritableFile file)`
`KeyValue<Long,Long>`	`exportTypeEntities(StorageEntityTypeHandler type, AWritableFile file, Predicate<? super StorageEntity> predicateEntity)`
`void`	`importData(StorageImportSourceFile importFile)`
`StorageIdAnalysis`	`initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory)`
`boolean`	`isActive()`	Queries whether the part is actually active right now.
`boolean`	`issuedEntityCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)`
`boolean`	`issuedFileCleanupCheck(long nanoTimeBudget)`
`boolean`	`issuedGarbageCollection(long nanoTimeBudget)`
`boolean`	`performEntityCacheCheck(long nanoTimeBudget)`
`boolean`	`performFileCleanupCheck(long nanoTimeBudget)`
`boolean`	`performGarbageCollection(long nanoTimeBudget)`
`boolean`	`performIssuedEntityCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator evaluator)`
`boolean`	`performIssuedFileCleanupCheck(long nanoTimeBudget)`
`boolean`	`performIssuedGarbageCollection(long nanoTimeBudget)`
`void`	`postStoreUpdateEntityCache(ByteBuffer[] chunks, long[] chunksStoragePositions)`
`StorageEntityCache.Default`	`prepareImportData()`
`StorageInventory`	`readStorage()`
`void`	`reset()`	Closes all resources (files, locks, etc.).
`void`	`rollbackChunkStorage()`
`void`	`rollbackImportData(Throwable cause)`
`void`	`run()`
`void`	`signalGarbageCollectionSweepCompleted()`
`KeyValue<ByteBuffer[],long[]>`	`storeEntities(long timestamp, Chunk chunkData)`
`StorageTypeDictionary`	`typeDictionary()`

Methods inherited from class java.lang.Object

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

Constructor Details
- Default
  
  public Default(int hashIndex, StorageExceptionHandler exceptionHandler, StorageTaskBroker taskBroker, StorageOperationController operationController, StorageHousekeepingBroker housekeepingBroker, StorageHousekeepingController housekeepingController, StorageEntityCache.Default entityCache, boolean switchByteOrder, BufferSizeProviderIncremental loadingBufferSizeProvider, StorageFileManager.Default fileManager, StorageEventLogger eventLogger)
Method Details
- performIssuedGarbageCollection
  
  public boolean performIssuedGarbageCollection(long nanoTimeBudget)
  
  Specified by:
  
  performIssuedGarbageCollection in interface StorageHousekeepingExecutor
- performIssuedFileCleanupCheck
  
  public boolean performIssuedFileCleanupCheck(long nanoTimeBudget)
  
  Specified by:
  
  performIssuedFileCleanupCheck in interface StorageHousekeepingExecutor
- performIssuedEntityCacheCheck
  
  public boolean performIssuedEntityCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator evaluator)
  
  Specified by:
  
  performIssuedEntityCacheCheck in interface StorageHousekeepingExecutor
- performFileCleanupCheck
  
  public final boolean performFileCleanupCheck(long nanoTimeBudget)
  
  Specified by:
  
  performFileCleanupCheck in interface StorageHousekeepingExecutor
- performGarbageCollection
  
  public boolean performGarbageCollection(long nanoTimeBudget)
  
  Specified by:
  
  performGarbageCollection in interface StorageHousekeepingExecutor
- performEntityCacheCheck
  
  public boolean performEntityCacheCheck(long nanoTimeBudget)
  
  Specified by:
  
  performEntityCacheCheck in interface StorageHousekeepingExecutor
- issuedGarbageCollection
  
  public final boolean issuedGarbageCollection(long nanoTimeBudget)
  
  Specified by:
  
  issuedGarbageCollection in interface StorageChannel
- issuedFileCleanupCheck
  
  public boolean issuedFileCleanupCheck(long nanoTimeBudget)
  
  Specified by:
  
  issuedFileCleanupCheck in interface StorageChannel
- issuedEntityCacheCheck
  
  public boolean issuedEntityCacheCheck(long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)
  
  Specified by:
  
  issuedEntityCacheCheck in interface StorageChannel
- isActive
  
  public boolean isActive()
  
  Description copied from interface: StorageActivePart
  
  Queries whether the part is actually active right now. This might return true even despite some "running" flag being set to false because there might be one last loop cycle execution before checking the "running" flag again.
  
  Specified by:
  
  isActive in interface StorageActivePart
  
  Returns:
  
  if the part is actually active right now.
- run
  
  public final void run()
  
  Specified by:
  
  run in interface Runnable
- commitChunkStorage
  
  public void commitChunkStorage()
  
  Specified by:
  
  commitChunkStorage in interface StorageChannel
- storeEntities
  
  public KeyValue<ByteBuffer[],long[]> storeEntities(long timestamp, Chunk chunkData)
  
  Specified by:
  
  storeEntities in interface StorageChannel
- postStoreUpdateEntityCache
  
  public void postStoreUpdateEntityCache(ByteBuffer[] chunks, long[] chunksStoragePositions) throws InterruptedException
  
  Specified by:
  
  postStoreUpdateEntityCache in interface StorageChannel
  
  Throws:
  
  InterruptedException
- channelIndex
  
  public final int channelIndex()
  
  Specified by:
  
  channelIndex in interface StorageHashChannelPart
- typeDictionary
  
  public final StorageTypeDictionary typeDictionary()
  
  Specified by:
  
  typeDictionary in interface StorageChannel
- collectLoadByOids
  
  public final ChunksBuffer collectLoadByOids(ChunksBuffer[] resultArray, PersistenceIdSet loadOids)
  
  Specified by:
  
  collectLoadByOids in interface StorageChannel
- collectLoadRoots
  
  public final ChunksBuffer collectLoadRoots(ChunksBuffer[] resultArray)
  
  Specified by:
  
  collectLoadRoots in interface StorageChannel
- collectLoadByTids
  
  public final ChunksBuffer collectLoadByTids(ChunksBuffer[] resultArray, PersistenceIdSet loadTids)
  
  Specified by:
  
  collectLoadByTids in interface StorageChannel
- exportData
  
  public final void exportData(StorageLiveFileProvider fileProvider)
  
  Specified by:
  
  exportData in interface StorageChannel
- prepareImportData
  
  public StorageEntityCache.Default prepareImportData()
  
  Specified by:
  
  prepareImportData in interface StorageChannel
- importData
  
  public void importData(StorageImportSourceFile importFile)
  
  Specified by:
  
  importData in interface StorageChannel
- rollbackImportData
  
  public void rollbackImportData(Throwable cause)
  
  Specified by:
  
  rollbackImportData in interface StorageChannel
- commitImportData
  
  public void commitImportData(long taskTimestamp)
  
  Specified by:
  
  commitImportData in interface StorageChannel
- exportTypeEntities
  
  public final KeyValue<Long,Long> exportTypeEntities(StorageEntityTypeHandler type, AWritableFile file, Predicate<? super StorageEntity> predicateEntity) throws IOException
  
  Specified by:
  
  exportTypeEntities in interface StorageChannel
  
  Throws:
  
  IOException
- exportTypeEntities
  
  public final KeyValue<Long,Long> exportTypeEntities(StorageEntityTypeHandler type, AWritableFile file) throws IOException
  
  Specified by:
  
  exportTypeEntities in interface StorageChannel
  
  Throws:
  
  IOException
- createRawFileStatistics
  
  public final StorageRawFileStatistics.ChannelStatistics createRawFileStatistics()
  
  Specified by:
  
  createRawFileStatistics in interface StorageChannel
- rollbackChunkStorage
  
  public final void rollbackChunkStorage()
  
  Specified by:
  
  rollbackChunkStorage in interface StorageChannel
- readStorage
  
  public final StorageInventory readStorage()
  
  Specified by:
  
  readStorage in interface StorageChannel
- initializeStorage
  
  public final StorageIdAnalysis initializeStorage(long taskTimestamp, long consistentStoreTimestamp, StorageInventory storageInventory)
  
  Specified by:
  
  initializeStorage in interface StorageChannel
- reset
  
  public final void reset()
  
  Closes all resources (files, locks, etc.). Clears all variable length items (cache, registry, etc.). Resets internal state to initial values. For itself and all its parts (entity cache, file manager, etc.). Basically a "back to just being born" action.
  
  Specified by:
  
  reset in interface StorageChannelResetablePart
- signalGarbageCollectionSweepCompleted
  
  public final void signalGarbageCollectionSweepCompleted()
  
  Specified by:
  
  signalGarbageCollectionSweepCompleted in interface StorageChannel
- cleanupStore
  
  public void cleanupStore()
  
  Specified by:
  
  cleanupStore in interface StorageChannel

Class StorageChannel.Default

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannel

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

Method Details