<s>[INST] helper method to get partitionoutgoingbatch based on the index since we may have more then one partitioner as number of partitioners should be very small and this method it used very rarely , so it is ok to loop in order to find right partitioner 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 void partitionBatch 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] PartitionOutgoingBatch function ( int arg0 ) { for ( Partitioner loc0 : partitioners ) { PartitionOutgoingBatch loc1 = loc0 . getOutgoingBatch ( arg0 ) ; if ( loc1 != null ) { return loc1 ; } } return null ; </s>