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