void function ( long arg0 ) { TaskContext . get ( ) . taskMetrics ( ) . incPeakExecutionMemory ( arg0 ) ; }
increase the peak execution memory for current task . 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 boolean hasNext concode_elem_sep long durationMs concode_elem_sep void processNext concode_elem_sep void append concode_elem_sep boolean shouldStop