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

    Modifier and Type
    Method
    Description
    void
    execute(Partitioner partitioner)