public class BatchPartitionWorkUnit extends BatchParallelWorkUnit
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<BatchPartitionWorkUnit> |
completedThreadQueue |
batchKernel, controller, jobExecutionImpl, notifyCallbackWhenDone
Constructor and Description |
---|
BatchPartitionWorkUnit(RuntimeJobExecution jobExecution,
PartitionsBuilderConfig config,
ServicesManager manager) |
Modifier and Type | Method and Description |
---|---|
void |
inheritStepContext(StepContextImpl sc) |
protected void |
markThreadCompleted() |
getBatchKernel, getBatchStatus, getController, getExitStatus, getJobExecutionImpl, isNotifyCallbackWhenDone, run, setBatchKernel, setJobExecutionImpl, setNotifyCallbackWhenDone
protected final BlockingQueue<BatchPartitionWorkUnit> completedThreadQueue
public BatchPartitionWorkUnit(RuntimeJobExecution jobExecution, PartitionsBuilderConfig config, ServicesManager manager)
protected void markThreadCompleted()
markThreadCompleted
in class BatchWorkUnit
public void inheritStepContext(StepContextImpl sc)
Copyright © 2017 The Apache Software Foundation. All rights reserved.