static PurgeRequest readFrom(DataInputStream stream, ClusterMap map) throws IOException {
      int correlationId = stream.readInt();
      String clientId = Utils.readIntString(stream);
      BlobId id = new BlobId(stream, map);
      long purgeTimeInMs = stream.readLong();
      return new PurgeRequest(correlationId, clientId, id, purgeTimeInMs, PURGE_MESSAGE_REQUEST_VERSION_1);
    }
Class to read protocol version 1 PurgeRequest from the stream.
ambry-protocol/src/main/java/com/github/ambry/protocol/PurgeRequest.java