src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java [54:115]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public void serialize(ByteBuf buf) {
        ByteBufUtils.writeLengthAndString(buf, user);
        ByteBufUtils.writeLengthAndString(buf, appId);
        ByteBufUtils.writeLengthAndString(buf, appAttempt);
        buf.writeInt(shuffleId);
        buf.writeInt(partitionId);
        buf.writeInt(taskAttemptIds.size());
        for (Long entry: taskAttemptIds) {
            buf.writeLong(entry);
        }
    }

    public static ConnectDownloadRequest deserialize(ByteBuf buf) {
        String user = ByteBufUtils.readLengthAndString(buf);
        String appId = ByteBufUtils.readLengthAndString(buf);
        String appAttempt = ByteBufUtils.readLengthAndString(buf);
        int shuffleId = buf.readInt();
        int partitionId = buf.readInt();
        int numTaskAttemptIds = buf.readInt();
        List<Long> taskAttemptIds = new ArrayList<>(numTaskAttemptIds);
        for (int i = 0; i < numTaskAttemptIds; i++) {
            long taskAttemptId = buf.readLong();
            taskAttemptIds.add(taskAttemptId);
        }
        return new ConnectDownloadRequest(user, appId, appAttempt, shuffleId, partitionId, taskAttemptIds);
    }

    public String getUser() {
        return user;
    }

    public String getAppId() {
        return appId;
    }

    public String getAppAttempt() {
        return appAttempt;
    }

    public int getShuffleId() {
        return shuffleId;
    }

    public int getPartitionId() {
        return partitionId;
    }

    public List<Long> getTaskAttemptIds() {
        return taskAttemptIds;
    }

    @Override
    public String toString() {
        return "ConnectDownloadRequest{" +
            "user='" + user + '\'' +
            ", appId='" + appId + '\'' +
            ", appAttempt='" + appAttempt + '\'' +
            ", shuffleId=" + shuffleId +
            ", partitionId=" + partitionId +
            ", taskAttemptIds=" + taskAttemptIds +
            '}';
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java [58:119]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public void serialize(ByteBuf buf) {
        ByteBufUtils.writeLengthAndString(buf, user);
        ByteBufUtils.writeLengthAndString(buf, appId);
        ByteBufUtils.writeLengthAndString(buf, appAttempt);
        buf.writeInt(shuffleId);
        buf.writeInt(partitionId);
        buf.writeInt(taskAttemptIds.size());
        for (Long entry: taskAttemptIds) {
            buf.writeLong(entry);
        }
    }

    public static ConnectDownloadRequest deserialize(ByteBuf buf) {
        String user = ByteBufUtils.readLengthAndString(buf);
        String appId = ByteBufUtils.readLengthAndString(buf);
        String appAttempt = ByteBufUtils.readLengthAndString(buf);
        int shuffleId = buf.readInt();
        int partitionId = buf.readInt();
        int numTaskAttemptIds = buf.readInt();
        List<Long> taskAttemptIds = new ArrayList<>(numTaskAttemptIds);
        for (int i = 0; i < numTaskAttemptIds; i++) {
            long taskAttemptId = buf.readLong();
            taskAttemptIds.add(taskAttemptId);
        }
        return new ConnectDownloadRequest(user, appId, appAttempt, shuffleId, partitionId, taskAttemptIds);
    }

    public String getUser() {
        return user;
    }

    public String getAppId() {
        return appId;
    }

    public String getAppAttempt() {
        return appAttempt;
    }

    public int getShuffleId() {
        return shuffleId;
    }

    public int getPartitionId() {
        return partitionId;
    }

    public List<Long> getTaskAttemptIds() {
        return taskAttemptIds;
    }

    @Override
    public String toString() {
        return "ConnectDownloadRequest{" +
                "user='" + user + '\'' +
                ", appId='" + appId + '\'' +
                ", appAttempt='" + appAttempt + '\'' +
                ", shuffleId=" + shuffleId +
                ", partitionId=" + partitionId +
                ", taskAttemptIds=" + taskAttemptIds +
                '}';
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -