Package one.microstream.storage.types
Class StorageRequestTaskLoad.Abstract
java.lang.Object
one.microstream.storage.types.StorageTask.Abstract
one.microstream.storage.types.StorageChannelTask.Abstract<ChunksBuffer>
one.microstream.storage.types.StorageRequestTaskLoad.Abstract
- All Implemented Interfaces:
StorageChannelTask
,StorageRequestTask
,StorageRequestTaskLoad
,StorageTask
- Direct Known Subclasses:
StorageRequestTaskLoadByOids.Default
,StorageRequestTaskLoadByTids.Default
,StorageRequestTaskLoadRoots.Default
- Enclosing interface:
- StorageRequestTaskLoad
public abstract static class StorageRequestTaskLoad.Abstract extends StorageChannelTask.Abstract<ChunksBuffer> implements StorageRequestTaskLoad
-
Nested Class Summary
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannelTask
StorageChannelTask.Abstract<R>
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageRequestTaskLoad
StorageRequestTaskLoad.Abstract
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageTask
StorageTask.Abstract, StorageTask.DummyTask
-
Field Summary
-
Constructor Summary
Constructors Modifier Constructor Description protected
Abstract(long timestamp, int channelCount, StorageOperationController controller)
-
Method Summary
Modifier and Type Method Description protected void
complete(StorageChannel channel, ChunksBuffer result)
ChunksBuffer
result()
protected ChunksBuffer[]
resultArray()
Methods inherited from class one.microstream.storage.types.StorageChannelTask.Abstract
addProblem, channelCount, cleanUp, finishProcessing, hasProblems, incrementCompletionProgress, incrementProcessingProgress, internalProcessBy, isComplete, isProcessed, problemForChannel, problems, processBy, waitOnCompletion, waitOnProcessing
Methods inherited from class one.microstream.storage.types.StorageTask.Abstract
awaitNext, next, setNext, timestamp
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.StorageTask
awaitNext, hasProblems, isComplete, next, problemForChannel, problems, processBy, setNext, timestamp, waitOnCompletion
-
Constructor Details
-
Method Details
-
resultArray
-
complete
- Specified by:
complete
in classStorageChannelTask.Abstract<ChunksBuffer>
- Throws:
InterruptedException
-
result
- Specified by:
result
in interfaceStorageRequestTaskLoad
- Throws:
StorageExceptionRequest
-