boolean reportSubtaskStats ( JobVertexID jobVertexId , SubtaskStateStats subtask ) { TaskStateStats taskStateStats = taskStats . get ( jobVertexId ) ; if ( taskStateStats != null && taskStateStats . reportSubtaskStats ( subtask ) ) { currentNumAcknowledgedSubtasks ++ ; latestAcknowledgedSubtask = subtask ; currentStateSize += subtask . getStateSize ( ) ; long alignmentBuffered = subtask . getAlignmentBuffered ( ) ; if ( alignmentBuffered > 0 ) { currentAlignmentBuffered += alignmentBuffered ; } return true ; } else { return false ; } }
Reports statistics for a single subtask .