Interface PartitionerDecorator.GeneralExecuteIface
- Enclosing class:
- PartitionerDecorator
protected static interface PartitionerDecorator.GeneralExecuteIface
Helper interface to generalize functionality executed in the thread
since it is absolutely the same for partitionBatch and flushOutgoingBatches
protected is for testing purposes
-
Method Summary
-
Method Details
-
execute
- Throws:
IOException
-