Package one.microstream.storage.types
Class StorageRequestTaskImportDataByteBuffers.Default
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<ByteBuffer>
one.microstream.storage.types.StorageRequestTaskImportDataByteBuffers.Default
- All Implemented Interfaces:
StorageChannelSynchronizingTask
,StorageChannelTask
,StorageChannelTaskStoreEntities
,StorageRequestTask
,StorageRequestTaskImportData<ByteBuffer>
,StorageRequestTaskImportDataByteBuffers
,StorageTask
- Enclosing interface:
- StorageRequestTaskImportDataByteBuffers
public static final class StorageRequestTaskImportDataByteBuffers.Default extends StorageRequestTaskImportData.Abstract<ByteBuffer> implements StorageRequestTaskImportDataByteBuffers
-
Nested Class Summary
Nested classes/interfaces inherited from class one.microstream.storage.types.StorageRequestTaskImportData.Abstract
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.StorageRequestTaskImportDataByteBuffers
StorageRequestTaskImportDataByteBuffers.Default
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 StorageImportSource.Abstract
createImportSource(int channelIndex, ByteBuffer buffer, StorageChannelImportBatch.Default headBatch)
protected void
iterateSource(ByteBuffer buffer, StorageRequestTaskImportData.Abstract.ItemAcceptor itemAcceptor)
Methods inherited from class one.microstream.storage.types.StorageRequestTaskImportData.Abstract
fail, internalProcessBy, postCompletionSuccess, succeed
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 StorageImportSource.Abstract createImportSource(int channelIndex, ByteBuffer buffer, StorageChannelImportBatch.Default headBatch)- Specified by:
createImportSource
in classStorageRequestTaskImportData.Abstract<ByteBuffer>
-
iterateSource
protected void iterateSource(ByteBuffer buffer, StorageRequestTaskImportData.Abstract.ItemAcceptor itemAcceptor)- Specified by:
iterateSource
in classStorageRequestTaskImportData.Abstract<ByteBuffer>
-