void function ( InternalRow arg0 ) { currentRows . add ( arg0 ) ; }
append a row to currentrows . concode_field_sep UnsafeRow unsafeRow concode_elem_sep long startTimeNs concode_elem_sep int partitionIndex concode_elem_sep LinkedList<InternalRow> currentRows concode_field_sep InternalRow next concode_elem_sep void init concode_elem_sep void incPeakExecutionMemory concode_elem_sep boolean hasNext concode_elem_sep long durationMs concode_elem_sep void processNext concode_elem_sep boolean shouldStop