nl: helper method to copy data based on partition concode_field_sep boolean dropAll concode_elem_sep RecordBatch incoming concode_elem_sep int DEFAULT_RECORD_BATCH_SIZE concode_elem_sep int outgoingRecordBatchSize concode_elem_sep int totalRecords concode_elem_sep org.slf4j.Logger logger concode_elem_sep int recordCount concode_elem_sep int start concode_elem_sep SelectionVector2 sv2 concode_elem_sep HashPartitionSender operator concode_elem_sep SelectionVector4 sv4 concode_elem_sep BufferAllocator allocator concode_elem_sep OperatorStats stats concode_elem_sep boolean isLast concode_elem_sep FragmentContext context concode_elem_sep int end concode_elem_sep List<OutgoingRecordBatch> outgoingBatches concode_elem_sep VectorContainer vectorContainer concode_elem_sep AccountingDataTunnel tunnel concode_elem_sep int oppositeMinorFragmentId concode_field_sep OperatorStats getStats concode_elem_sep void initializeBatch concode_elem_sep List<? extends PartitionOutgoingBatch> getOutgoingBatches concode_elem_sep Iterator<VectorWrapper<?>> iterator concode_elem_sep void setIsLast concode_elem_sep void flush concode_elem_sep int getRecordCount concode_elem_sep void resetBatch concode_elem_sep long getTotalRecords concode_elem_sep void copy concode_elem_sep int doEval concode_elem_sep void doEval concode_elem_sep WritableBatch getWritableBatch concode_elem_sep void clear concode_elem_sep void clear concode_elem_sep void doSetup concode_elem_sep void doSetup concode_elem_sep VectorWrapper<?> getValueAccessorById concode_elem_sep PartitionOutgoingBatch getOutgoingBatch concode_elem_sep BatchSchema getSchema concode_elem_sep void partitionBatch concode_elem_sep void allocateOutgoingRecordBatch concode_elem_sep SelectionVector4 getSelectionVector4 concode_elem_sep SelectionVector2 getSelectionVector2 concode_elem_sep TypedFieldId getValueVectorId concode_elem_sep void setup concode_elem_sep void flushOutgoingBatches concode_elem_sep void terminate concode_elem_sep void updateStats
code: void function ( int arg0 ) { int loc0 = doEval ( arg0 ) ; if ( loc0 >= start && loc0 < end ) { OutgoingRecordBatch loc1 = outgoingBatches . get ( loc0 - start ) ; loc1 . copy ( arg0 ) ; } }