O
- the type of the operation that are processed by this navigation processorpublic class BucketQueryOperationNavigationProcessor<O extends QueryOperation<?>> extends AbstractNavigationProcessor<O,Bucket>
NavigationProcessor
that processes any QueryOperation
on a set of Bucket
s.
The buckets where the operation should be processed is provided via constructor.
Constructor and Description |
---|
BucketQueryOperationNavigationProcessor(O operation,
boolean cloneAsynchronousOperation)
Create a new bucket navigation processor.
|
BucketQueryOperationNavigationProcessor(O operation,
boolean cloneAsynchronousOperation,
java.util.Collection<? extends Bucket> buckets)
Create a new bucket navigation processor.
|
Modifier and Type | Method and Description |
---|---|
protected O |
processItem(O operation,
Bucket processingItem)
Processes the encapsulated operation using the given processing item.
|
abort, addProcessingItem, addProcessingItems, close, getNextProcessingItem, getOperation, getProcessedCount, getRemainingCount, isFinished, isQueueClosed, processStep, processStepAsynchronously, queueClose, stepFinished
public BucketQueryOperationNavigationProcessor(O operation, boolean cloneAsynchronousOperation, java.util.Collection<? extends Bucket> buckets)
closed
and contains only the specified buckets.
No additional buckets can be added.operation
- the operation to processcloneAsynchronousOperation
- the flag whether to clone the operation for asynchronous processingbuckets
- the buckets on which to processpublic BucketQueryOperationNavigationProcessor(O operation, boolean cloneAsynchronousOperation)
AbstractNavigationProcessor.processStep()
. Additional buckets must be
added via AbstractNavigationProcessor.addProcessingItem(T)
methods and then closed
in order to be able to finish the processing.operation
- the operation to processcloneAsynchronousOperation
- the flag whether to clone the operation for asynchronous processingprotected O processItem(O operation, Bucket processingItem) throws AlgorithmMethodException
AbstractNavigationProcessor
processItem
in class AbstractNavigationProcessor<O extends QueryOperation<?>,Bucket>
operation
- the operation that is to be processedprocessingItem
- the processing item using which to process the operationAlgorithmMethodException
- if an error occurred during the evaluation of the processing step