Skip to content

Commit

Permalink
[hotfix][rest] Remove redundant comments in SubtaskStateStats
Browse files Browse the repository at this point in the history
  • Loading branch information
pnowojski committed Jan 29, 2020
1 parent 06a1624 commit f87879c
Showing 1 changed file with 8 additions and 38 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,6 @@ public class SubtaskStateStats implements Serializable {

private static final long serialVersionUID = 8928594531621862214L;

/** Index of this sub task. */
private final int subtaskIndex;

/**
Expand All @@ -60,17 +59,6 @@ public class SubtaskStateStats implements Serializable {
/** Alignment duration in . */
private final long alignmentDuration;

/**
* Creates the stats for a single subtask.
*
* @param subtaskIndex Index of the subtask.
* @param ackTimestamp Timestamp when the acknowledgement of this subtask was received at the coordinator.
* @param stateSize Size of the checkpointed state at this subtask.
* @param syncCheckpointDuration Checkpoint duration at the task (synchronous part)
* @param asyncCheckpointDuration Checkpoint duration at the task (asynchronous part)
* @param alignmentBuffered Bytes buffered during stream alignment (for exactly-once only).
* @param alignmentDuration Duration of the stream alignment (for exactly-once only).
*/
SubtaskStateStats(
int subtaskIndex,
long ackTimestamp,
Expand All @@ -91,11 +79,6 @@ public class SubtaskStateStats implements Serializable {
this.alignmentDuration = alignmentDuration;
}

/**
* Returns the subtask index.
*
* @return Subtask index.
*/
public int getSubtaskIndex() {
return subtaskIndex;
}
Expand Down Expand Up @@ -133,45 +116,32 @@ public long getEndToEndDuration(long triggerTimestamp) {
}

/**
* Returns the duration of the synchronous part of the checkpoint.
*
* <p>Can return <code>-1</code> if the runtime did not report this.
*
* @return Duration of the synchronous part of the checkpoint or <code>-1</code>.
* @return Duration of the synchronous part of the checkpoint or <code>-1</code> if the runtime
* did not report this.
*/
public long getSyncCheckpointDuration() {
return syncCheckpointDuration;
}

/**
* Returns the duration of the asynchronous part of the checkpoint.
*
* <p>Can return <code>-1</code> if the runtime did not report this.
*
* @return Duration of the asynchronous part of the checkpoint or <code>-1</code>.
* @return Duration of the asynchronous part of the checkpoint or <code>-1</code> if the runtime
* did not report this.
*/
public long getAsyncCheckpointDuration() {
return asyncCheckpointDuration;
}

/**
* Returns the number of bytes buffered during stream alignment (for
* exactly-once only).
*
* <p>Can return <code>-1</code> if the runtime did not report this.
*
* @return Number of bytes buffered during stream alignment or <code>-1</code>.
* @return Number of bytes buffered during stream alignment (for exactly-once only) or
* <code>-1</code> if the runtime did not report this.
*/
public long getAlignmentBuffered() {
return alignmentBuffered;
}

/**
* Returns the duration of the stream alignment (for exactly-once only).
*
* <p>Can return <code>-1</code> if the runtime did not report this.
*
* @return Duration of the stream alignment or <code>-1</code>.
* @return Duration of the stream alignment (for exactly-once only) or <code>-1</code> if the
* runtime did not report this.
*/
public long getAlignmentDuration() {
return alignmentDuration;
Expand Down

0 comments on commit f87879c

Please sign in to comment.