<s>[INST] partitionbatch - decorator method to call real partitioner s to process incoming batch uses either threading or not threading approach based on number partitioners concode_field_sep RecordBatch incoming concode_elem_sep boolean isLastBatch concode_elem_sep Partitioner part concode_elem_sep org.slf4j.Logger logger concode_elem_sep String childThreadPrefix concode_elem_sep GeneralExecuteIface iface concode_elem_sep ControlsInjector injector concode_elem_sep String parentThreadName concode_elem_sep CountDownLatchInjection testCountDownLatch concode_elem_sep OperatorStats stats concode_elem_sep ExecutorService executor concode_elem_sep String tName concode_elem_sep FragmentContext context concode_elem_sep boolean schemaChanged concode_elem_sep CountDownLatch latch concode_elem_sep IOException exp concode_elem_sep List<Partitioner> partitioners concode_field_sep PartitionOutgoingBatch getOutgoingBatches concode_elem_sep IOException getException concode_elem_sep List<Partitioner> getPartitioners concode_elem_sep void clear concode_elem_sep void flushOutgoingBatches concode_elem_sep void executeMethodLogic concode_elem_sep void run concode_elem_sep Partitioner getPart concode_elem_sep void initialize concode_elem_sep void execute concode_elem_sep void execute concode_elem_sep void execute [/INST] void function ( final RecordBatch arg0 ) { executeMethodLogic ( new PartitionBatchHandlingClass ( arg0 ) ) ; </s>