Package org.apache.batchee.container.util

Class BatchFlowInSplitWorkUnit

java.lang.Object

org.apache.batchee.container.util.BatchWorkUnit

org.apache.batchee.container.util.BatchParallelWorkUnit

org.apache.batchee.container.util.BatchFlowInSplitWorkUnit

All Implemented Interfaces:

Runnable

public class BatchFlowInSplitWorkUnit
extends BatchParallelWorkUnit

Field Summary

Fields

Modifier and Type	Field	Description
protected BlockingQueue<BatchFlowInSplitWorkUnit>	completedThreadQueue

Fields inherited from class org.apache.batchee.container.util.BatchWorkUnit

batchKernel, controller, jobExecutionImpl, notifyCallbackWhenDone

Constructor Summary

Constructors

Constructor	Description
BatchFlowInSplitWorkUnit(RuntimeFlowInSplitExecution jobExecution, FlowInSplitBuilderConfig config, ServicesManager manager)

Method Summary

Modifier and Type	Method	Description
RuntimeFlowInSplitExecution	getJobExecutionImpl()
protected void	markThreadCompleted()

Methods inherited from class org.apache.batchee.container.util.BatchWorkUnit

getBatchKernel, getBatchStatus, getController, getExitStatus, isNotifyCallbackWhenDone, run, setBatchKernel, setJobExecutionImpl, setNotifyCallbackWhenDone

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

completedThreadQueue

protected final BlockingQueue<BatchFlowInSplitWorkUnit> completedThreadQueue

Constructor Detail

BatchFlowInSplitWorkUnit

public BatchFlowInSplitWorkUnit(RuntimeFlowInSplitExecution jobExecution,
                                FlowInSplitBuilderConfig config,
                                ServicesManager manager)

Method Detail

markThreadCompleted

protected void markThreadCompleted()

Overrides:

markThreadCompleted in class BatchWorkUnit

getJobExecutionImpl

public RuntimeFlowInSplitExecution getJobExecutionImpl()

Overrides:

getJobExecutionImpl in class BatchWorkUnit