- private AtomicInteger remainingTxReturn = new AtomicInteger(0);
-
- public FlowHandlerTask(final String dpId,
- final int flowsPerDpn,
- final boolean add,
- final int batchSize,
- final int sleepMillis,
- final int sleepAfter,
- final short startTableId,
- final short endTableId){
+ private final AtomicInteger remainingTxReturn = new AtomicInteger(0);
+ private final boolean isCreateParents;
+
+ FlowHandlerTask(final String dpId, final int flowsPerDpn,
+ final boolean add, final int batchSize,
+ final int sleepMillis, final int sleepAfter,
+ final short startTableId, final short endTableId,
+ final boolean isCreateParents) {