public class ThreadPartitionWorker extends Object implements PartitionWorker
Constructor and Description |
---|
ThreadPartitionWorker(BlockingQueue<Boolean> completedPartitionThreads,
BlockingQueue<Serializable> collectorDataQueue) |
Modifier and Type | Method and Description |
---|---|
void |
partitionDone(AbstractStepExecution partitionExecution) |
void |
reportData(Serializable data,
AbstractStepExecution partitionExecution) |
public ThreadPartitionWorker(BlockingQueue<Boolean> completedPartitionThreads, BlockingQueue<Serializable> collectorDataQueue)
public void reportData(Serializable data, AbstractStepExecution partitionExecution) throws Exception
reportData
in interface PartitionWorker
Exception
public void partitionDone(AbstractStepExecution partitionExecution) throws Exception
partitionDone
in interface PartitionWorker
Exception
Copyright © 2020 JBoss by Red Hat. All rights reserved.