Package one.microstream.storage.types

Class StorageRequestTaskCreator.Default

java.lang.Object

one.microstream.storage.types.StorageRequestTaskCreator.Default

All Implemented Interfaces:

StorageRequestTaskCreator

Enclosing interface:

StorageRequestTaskCreator

public static final class StorageRequestTaskCreator.Default
extends Object
implements StorageRequestTaskCreator

Nested Class Summary

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

StorageRequestTaskCreator.Default

Constructor Summary

Constructors

Constructor	Description
Default(StorageTimestampProvider timestampProvider)

Method Summary

Modifier and Type	Method	Description
StorageRequestTaskCreateStatistics	createCreateRawFileStatisticsTask(int channelCount)
StorageRequestTaskExportEntitiesByType	createExportTypesTask(int channelCount, StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType)
StorageRequestTaskCacheCheck	createFullCacheCheckTask(int channelCount, long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)
StorageRequestTaskFileCheck	createFullFileCheckTask(int channelCount, long nanoTimeBudget)
StorageRequestTaskImportData	createImportFromFilesTask(int channelCount, StorageDataFileEvaluator fileEvaluator, StorageObjectIdRangeEvaluator objectIdRangeEvaluator, XGettingEnum<AFile> importFiles)
StorageChannelTaskInitialize	createInitializationTask(int channelCount, StorageOperationController operationController)
StorageRequestTaskLoadByOids	createLoadTaskByOids(PersistenceIdSet[] loadOids)
StorageRequestTaskLoadByTids	createLoadTaskByTids(PersistenceIdSet loadTids, int channelCount)
StorageRequestTaskLoadRoots	createRootsLoadTask(int channelCount)
StorageRequestTaskStoreEntities	createSaveTask(Binary data)
StorageChannelTaskShutdown	createShutdownTask(int channelCount, StorageOperationController operationController)
StorageRequestTaskExportChannels	createTaskExportChannels(int channelCount, StorageLiveFileProvider fileProvider)

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.storage.types.StorageRequestTaskCreator

createExportTypesTask

Constructor Details

Default

public Default(StorageTimestampProvider timestampProvider)

Method Details

createInitializationTask

public StorageChannelTaskInitialize createInitializationTask(int channelCount, StorageOperationController operationController)

Specified by:

createInitializationTask in interface StorageRequestTaskCreator

createShutdownTask

public StorageChannelTaskShutdown createShutdownTask(int channelCount, StorageOperationController operationController)

Specified by:

createShutdownTask in interface StorageRequestTaskCreator

createSaveTask

public StorageRequestTaskStoreEntities createSaveTask(Binary data)

Specified by:

createSaveTask in interface StorageRequestTaskCreator

createLoadTaskByOids

public StorageRequestTaskLoadByOids createLoadTaskByOids(PersistenceIdSet[] loadOids)

Specified by:

createLoadTaskByOids in interface StorageRequestTaskCreator

createRootsLoadTask

public StorageRequestTaskLoadRoots createRootsLoadTask(int channelCount)

Specified by:

createRootsLoadTask in interface StorageRequestTaskCreator

createLoadTaskByTids

public StorageRequestTaskLoadByTids createLoadTaskByTids(PersistenceIdSet loadTids, int channelCount)

Specified by:

createLoadTaskByTids in interface StorageRequestTaskCreator

createExportTypesTask

public StorageRequestTaskExportEntitiesByType createExportTypesTask(int channelCount, StorageEntityTypeExportFileProvider exportFileProvider, Predicate<? super StorageEntityTypeHandler> isExportType)

Specified by:

createExportTypesTask in interface StorageRequestTaskCreator

createTaskExportChannels

public StorageRequestTaskExportChannels createTaskExportChannels(int channelCount, StorageLiveFileProvider fileProvider)

Specified by:

createTaskExportChannels in interface StorageRequestTaskCreator

createCreateRawFileStatisticsTask

public StorageRequestTaskCreateStatistics createCreateRawFileStatisticsTask(int channelCount)

Specified by:

createCreateRawFileStatisticsTask in interface StorageRequestTaskCreator

createFullFileCheckTask

public StorageRequestTaskFileCheck createFullFileCheckTask(int channelCount, long nanoTimeBudget)

Specified by:

createFullFileCheckTask in interface StorageRequestTaskCreator

createFullCacheCheckTask

public StorageRequestTaskCacheCheck createFullCacheCheckTask(int channelCount, long nanoTimeBudget, StorageEntityCacheEvaluator entityEvaluator)

Specified by:

createFullCacheCheckTask in interface StorageRequestTaskCreator

createImportFromFilesTask

public StorageRequestTaskImportData createImportFromFilesTask(int channelCount, StorageDataFileEvaluator fileEvaluator, StorageObjectIdRangeEvaluator objectIdRangeEvaluator, XGettingEnum<AFile> importFiles)

Specified by:

createImportFromFilesTask in interface StorageRequestTaskCreator