public interface PartitionHandler
Modifier and Type | Method and Description |
---|---|
default void |
close(StepContextImpl stepContext) |
void |
setCollectorDataQueue(BlockingQueue<Serializable> collectorDataQueue) |
void |
setResourceTracker(BlockingQueue<Boolean> completedPartitionThreads) |
void |
submitPartitionTask(StepContextImpl partitionStepContext,
int currentIndex,
int numOfPartitions) |
void setResourceTracker(BlockingQueue<Boolean> completedPartitionThreads)
void setCollectorDataQueue(BlockingQueue<Serializable> collectorDataQueue)
void submitPartitionTask(StepContextImpl partitionStepContext, int currentIndex, int numOfPartitions) throws Exception
Exception
default void close(StepContextImpl stepContext)
Copyright © 2019 JBoss by Red Hat. All rights reserved.