Package one.microstream.storage.types
Class StorageRequestTaskStoreEntities.Default
java.lang.Object
one.microstream.storage.types.StorageTask.Abstract
one.microstream.storage.types.StorageChannelTask.Abstract<R>
one.microstream.storage.types.StorageChannelSynchronizingTask.AbstractCompletingTask<KeyValue<ByteBuffer[],long[]>>
one.microstream.storage.types.StorageRequestTaskStoreEntities.Default
- All Implemented Interfaces:
StorageChannelSynchronizingTask
,StorageChannelTask
,StorageChannelTaskStoreEntities
,StorageRequestTask
,StorageRequestTaskStoreEntities
,StorageTask
- Enclosing interface:
- StorageRequestTaskStoreEntities
public static final class StorageRequestTaskStoreEntities.Default extends StorageChannelSynchronizingTask.AbstractCompletingTask<KeyValue<ByteBuffer[],long[]>> implements StorageRequestTaskStoreEntities, StorageChannelTaskStoreEntities
-
Nested Class Summary
Nested classes/interfaces inherited from class one.microstream.storage.types.StorageChannelSynchronizingTask.AbstractCompletingTask
StorageChannelSynchronizingTask.AbstractCompletingTask.Dummy
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannelSynchronizingTask
StorageChannelSynchronizingTask.AbstractCompletingTask<R>
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannelTask
StorageChannelTask.Abstract<R>
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageRequestTaskStoreEntities
StorageRequestTaskStoreEntities.Default
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageTask
StorageTask.Abstract, StorageTask.DummyTask
-
Method Summary
Modifier and Type Method Description protected void
cleanUp(StorageChannel channel)
void
DEBUG_Print(StorageChannel channel)
protected void
fail(StorageChannel channel, KeyValue<ByteBuffer[],long[]> result)
protected KeyValue<ByteBuffer[],long[]>
internalProcessBy(StorageChannel channel)
protected void
postCompletionSuccess(StorageChannel channel, KeyValue<ByteBuffer[],long[]> result)
protected void
succeed(StorageChannel channel, KeyValue<ByteBuffer[],long[]> result)
Methods inherited from class one.microstream.storage.types.StorageChannelSynchronizingTask.AbstractCompletingTask
complete
Methods inherited from class one.microstream.storage.types.StorageChannelTask.Abstract
addProblem, channelCount, finishProcessing, hasProblems, incrementCompletionProgress, incrementProcessingProgress, 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.StorageChannelSynchronizingTask
incrementProcessingProgress, isProcessed, waitOnProcessing
Methods inherited from interface one.microstream.storage.types.StorageChannelTask
addProblem, incrementCompletionProgress
Methods inherited from interface one.microstream.storage.types.StorageTask
awaitNext, hasProblems, isComplete, next, problemForChannel, problems, processBy, setNext, timestamp, waitOnCompletion
-
Method Details
-
internalProcessBy
- Overrides:
internalProcessBy
in classStorageChannelSynchronizingTask.AbstractCompletingTask<KeyValue<ByteBuffer[],long[]>>
-
DEBUG_Print
-
succeed
- Overrides:
succeed
in classStorageChannelSynchronizingTask.AbstractCompletingTask<KeyValue<ByteBuffer[],long[]>>
-
postCompletionSuccess
protected final void postCompletionSuccess(StorageChannel channel, KeyValue<ByteBuffer[],long[]> result) throws InterruptedException- Overrides:
postCompletionSuccess
in classStorageChannelSynchronizingTask.AbstractCompletingTask<KeyValue<ByteBuffer[],long[]>>
- Throws:
InterruptedException
-
fail
- Overrides:
fail
in classStorageChannelSynchronizingTask.AbstractCompletingTask<KeyValue<ByteBuffer[],long[]>>
-
cleanUp
- Overrides:
cleanUp
in classStorageChannelTask.Abstract<KeyValue<ByteBuffer[],long[]>>
-