Package one.microstream.storage.types
Class StorageRequestTaskImportData.Abstract<S>
java.lang.Object
one.microstream.storage.types.StorageTask.Abstract
one.microstream.storage.types.StorageChannelTask.Abstract<R>
one.microstream.storage.types.StorageChannelSynchronizingTask.AbstractCompletingTask<Void>
one.microstream.storage.types.StorageRequestTaskImportData.Abstract<S>
- All Implemented Interfaces:
StorageChannelSynchronizingTask
,StorageChannelTask
,StorageChannelTaskStoreEntities
,StorageRequestTask
,StorageRequestTaskImportData<S>
,StorageTask
- Direct Known Subclasses:
StorageRequestTaskImportDataByteBuffers.Default
,StorageRequestTaskImportDataFiles.Default
- Enclosing interface:
- StorageRequestTaskImportData<S>
public abstract static class StorageRequestTaskImportData.Abstract<S> extends StorageChannelSynchronizingTask.AbstractCompletingTask<Void> implements StorageRequestTaskImportData<S>, StorageChannelTaskStoreEntities
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
StorageRequestTaskImportData.Abstract.ItemAcceptor
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.StorageRequestTaskImportData
StorageRequestTaskImportData.Abstract<S>
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageTask
StorageTask.Abstract, StorageTask.DummyTask
-
Field Summary
-
Method Summary
Modifier and Type Method Description protected abstract StorageImportSource.Abstract
createImportSource(int channelIndex, S source, StorageChannelImportBatch.Default headBatch)
protected void
fail(StorageChannel channel, Void result)
protected Void
internalProcessBy(StorageChannel channel)
protected abstract void
iterateSource(S source, StorageRequestTaskImportData.Abstract.ItemAcceptor itemAcceptor)
protected void
postCompletionSuccess(StorageChannel channel, Void result)
protected void
succeed(StorageChannel channel, Void result)
Methods inherited from class one.microstream.storage.types.StorageChannelSynchronizingTask.AbstractCompletingTask
complete
Methods inherited from class one.microstream.storage.types.StorageChannelTask.Abstract
addProblem, channelCount, cleanUp, 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
-
createImportSource
protected abstract StorageImportSource.Abstract createImportSource(int channelIndex, S source, StorageChannelImportBatch.Default headBatch) -
iterateSource
protected abstract void iterateSource(S source, StorageRequestTaskImportData.Abstract.ItemAcceptor itemAcceptor) -
internalProcessBy
- Overrides:
internalProcessBy
in classStorageChannelSynchronizingTask.AbstractCompletingTask<Void>
-
succeed
- Overrides:
succeed
in classStorageChannelSynchronizingTask.AbstractCompletingTask<Void>
-
postCompletionSuccess
protected void postCompletionSuccess(StorageChannel channel, Void result) throws InterruptedException- Overrides:
postCompletionSuccess
in classStorageChannelSynchronizingTask.AbstractCompletingTask<Void>
- Throws:
InterruptedException
-
fail
- Overrides:
fail
in classStorageChannelSynchronizingTask.AbstractCompletingTask<Void>
-