public class ThreadPartitionHandler extends Object implements PartitionHandler
Constructor and Description |
---|
ThreadPartitionHandler(StepExecutionRunner stepExecutionRunner) |
Modifier and Type | Method and Description |
---|---|
void |
setCollectorDataQueue(BlockingQueue<Serializable> collectorDataQueue) |
void |
setResourceTracker(BlockingQueue<Boolean> completedPartitionThreads) |
void |
submitPartitionTask(StepContextImpl partitionStepContext,
int currentIndex,
int numOfPartitions) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public ThreadPartitionHandler(StepExecutionRunner stepExecutionRunner)
public void setResourceTracker(BlockingQueue<Boolean> completedPartitionThreads)
setResourceTracker
in interface PartitionHandler
public void setCollectorDataQueue(BlockingQueue<Serializable> collectorDataQueue)
setCollectorDataQueue
in interface PartitionHandler
public void submitPartitionTask(StepContextImpl partitionStepContext, int currentIndex, int numOfPartitions)
submitPartitionTask
in interface PartitionHandler
Copyright © 2020 JBoss by Red Hat. All rights reserved.