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

    All Methods Instance Methods Concrete Methods
    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`