src/main/java/com/uber/rss/clients/TaskByteArrayDataBlock.java [31:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.payload = payload;
        this.taskAttemptId = taskAttemptId;
    }

    @Nullable
    public byte[] getPayload() {
        return payload;
    }

    public long getTaskAttemptId() {
        return taskAttemptId;
    }

    public long totalBytes() {
        long bytes = 0L;
        if (payload != null) {
            bytes += payload.length;
        }
        return bytes;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/TaskDataBlock.java [31:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.payload = payload;
        this.taskAttemptId = taskAttemptId;
    }

    @Nullable
    public byte[] getPayload() {
        return payload;
    }

    public long getTaskAttemptId() {
        return taskAttemptId;
    }

    public long totalBytes() {
        long bytes = 0L;
        if (payload != null) {
            bytes += payload.length;
        }
        return bytes;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -