IGNITE-27942 Messages cleanup (#12786)

Author: anton-vinogradov

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteErrorMessage.java

@@ -55,23 +55,13 @@ public UUID queryId() {
         return qryId;
     }
 
-    /** */
-    public void queryId(UUID qryId) {
-        this.qryId = qryId;
-    }
-
     /**
      * @return Fragment ID.
      */
     public long fragmentId() {
         return fragmentId;
     }
 
-    /** */
-    public void fragmentId(long fragmentId) {
-        this.fragmentId = fragmentId;
-    }
-
     /** {@inheritDoc} */
     @Override public MessageType type() {
         return MessageType.QUERY_ERROR_MESSAGE;

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/GenericValueMessage.java

@@ -48,20 +48,6 @@ public GenericValueMessage(Object val) {
         return val;
     }
 
-    /**
-     * @return Serialized value.
-     */
-    public byte[] serialized() {
-        return serialized;
-    }
-
-    /**
-     * @param serialized Serialized value.
-     */
-    public void serialized(byte[] serialized) {
-        this.serialized = serialized;
-    }
-
     /** {@inheritDoc} */
     @Override public void prepareMarshal(GridCacheSharedContext<?, ?> ctx) throws IgniteCheckedException {
         if (val != null && serialized == null)

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCloseMessage.java

@@ -55,41 +55,20 @@ public UUID queryId() {
         return qryId;
     }
 
-    /**
-     * @param queryId New query ID.
-     */
-    public void queryId(UUID qryId) {
-        this.qryId = qryId;
-    }
-
     /**
      * @return Fragment ID.
      */
     public long fragmentId() {
         return fragmentId;
     }
 
-    /**
-     * @param fragmentId New fragment ID.
-     */
-    public void fragmentId(long fragmentId) {
-        this.fragmentId = fragmentId;
-    }
-
     /**
      * @return Exchange ID.
      */
     public long exchangeId() {
         return exchangeId;
     }
 
-    /**
-     * @param exchangeId New exchange ID.
-     */
-    public void exchangeId(long exchangeId) {
-        this.exchangeId = exchangeId;
-    }
-
     /** {@inheritDoc} */
     @Override public MessageType type() {
         return MessageType.QUERY_INBOX_CANCEL_MESSAGE;

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java

@@ -58,53 +58,25 @@ public QueryBatchAcknowledgeMessage(UUID qryId, long fragmentId, long exchangeId
         return qryId;
     }
 
-    /**
-     * @param qryId New query ID.
-     */
-    public void queryId(UUID qryId) {
-        this.qryId = qryId;
-    }
-
     /** {@inheritDoc} */
     @Override public long fragmentId() {
         return fragmentId;
     }
 
-    /**
-     * @param fragmentId New fragment ID.
-     */
-    public void fragmentId(long fragmentId) {
-        this.fragmentId = fragmentId;
-    }
-
     /**
      * @return Exchange ID.
      */
     public long exchangeId() {
         return exchangeId;
     }
 
-    /**
-     * @param exchangeId New exchange ID.
-     */
-    public void exchangeId(long exchangeId) {
-        this.exchangeId = exchangeId;
-    }
-
     /**
      * @return Batch ID.
      */
     public int batchId() {
         return batchId;
     }
 
-    /**
-     * @param batchId New batch ID.
-     */
-    public void batchId(int batchId) {
-        this.batchId = batchId;
-    }
-
     /** {@inheritDoc} */
     @Override public MessageType type() {
         return MessageType.QUERY_ACKNOWLEDGE_MESSAGE;

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java

@@ -74,88 +74,39 @@ public QueryBatchMessage(UUID qryId, long fragmentId, long exchangeId, int batch
         return qryId;
     }
 
-    /**
-     * @param qryId Query ID.
-     */
-    public void queryId(UUID qryId) {
-        this.qryId = qryId;
-    }
-
     /** {@inheritDoc} */
     @Override public long fragmentId() {
         return fragmentId;
     }
 
-    /**
-     * @param fragmentId Fragment ID.
-     */
-    public void fragmentId(long fragmentId) {
-        this.fragmentId = fragmentId;
-    }
-
     /**
      * @return Exchange ID.
      */
     public long exchangeId() {
         return exchangeId;
     }
 
-    /**
-     * @param exchangeId Exchange ID.
-     */
-    public void exchangeId(long exchangeId) {
-        this.exchangeId = exchangeId;
-    }
-
     /**
      * @return Batch ID.
      */
     public int batchId() {
         return batchId;
     }
 
-    /**
-     * @param batchId Batch ID.
-     */
-    public void batchId(int batchId) {
-        this.batchId = batchId;
-    }
-
     /**
      * @return Last batch flag.
      */
     public boolean last() {
         return last;
     }
 
-    /**
-     * @param last Last batch flag.
-     */
-    public void last(boolean last) {
-        this.last = last;
-    }
-
     /**
      * @return Rows.
      */
     public List<Object> rows() {
         return rows;
     }
 
-    /**
-     * @return Message rows.
-     */
-    public List<ValueMessage> messageRows() {
-        return mRows;
-    }
-
-    /**
-     * @param mRows Message rows.
-     */
-    public void messageRows(List<ValueMessage> mRows) {
-        this.mRows = mRows;
-    }
-
     /** {@inheritDoc} */
     @Override public void prepareMarshal(GridCacheSharedContext<?, ?> ctx) throws IgniteCheckedException {
         if (mRows != null || rows == null)

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryCloseMessage.java

@@ -45,13 +45,6 @@ public UUID queryId() {
         return qryId;
     }
 
-    /**
-     * @param qryId New query ID.
-     */
-    public void queryId(UUID qryId) {
-        this.qryId = qryId;
-    }
-
     /** {@inheritDoc} */
     @Override public MessageType type() {
         return MessageType.QUERY_CLOSE_MESSAGE;

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java

@@ -119,43 +119,18 @@ public String schema() {
         return schema;
     }
 
-    /** */
-    public void schema(String schema) {
-        this.schema = schema;
-    }
-
     /** {@inheritDoc} */
     @Override public UUID queryId() {
         return qryId;
     }
 
-    /** */
-    public void queryId(UUID qryId) {
-        this.qryId = qryId;
-    }
-
     /**
      * @return Registered local query ID on originating node.
      */
     public long originatingQueryId() {
         return originatingQryId;
     }
 
-    /** */
-    public void originatingQueryId(long originatingQryId) {
-        this.originatingQryId = originatingQryId;
-    }
-
-    /** */
-    public @Nullable byte[] parametersBytes() {
-        return paramsBytes;
-    }
-
-    /** */
-    public void parametersBytes(@Nullable byte[] paramsBytes) {
-        this.paramsBytes = paramsBytes;
-    }
-
     /** {@inheritDoc} */
     @Override public long fragmentId() {
         return fragmentDesc.fragmentId();
@@ -168,47 +143,27 @@ public FragmentDescription fragmentDescription() {
         return fragmentDesc;
     }
 
-    /** */
-    public void fragmentDescription(FragmentDescription fragmentDesc) {
-        this.fragmentDesc = fragmentDesc;
-    }
-
     /**
      * @return Topology version.
      */
     public AffinityTopologyVersion topologyVersion() {
         return ver;
     }
 
-    /** */
-    public void topologyVersion(AffinityTopologyVersion ver) {
-        this.ver = ver;
-    }
-
     /**
      * @return Fragment plan.
      */
     public String root() {
         return root;
     }
 
-    /** */
-    public void root(String root) {
-        this.root = root;
-    }
-
     /**
      * @return Total count of fragments in query for this node.
      */
     public int totalFragmentsCount() {
         return totalFragmentsCnt;
     }
 
-    /** */
-    public void totalFragmentsCount(int totalFragmentsCnt) {
-        this.totalFragmentsCnt = totalFragmentsCnt;
-    }
-
     /**
      * @return Query parameters.
      */
@@ -232,38 +187,18 @@ public long timeout() {
         return timeout;
     }
 
-    /** */
-    public void timeout(long timeout) {
-        this.timeout = timeout;
-    }
-
-    /** */
-    public void parametersBytes(long timeout) {
-        this.timeout = timeout;
-    }
-
     /**
      * @return Transaction entries to mixin on query processing.
      */
     public @Nullable Collection<QueryTxEntry> queryTransactionEntries() {
         return qryTxEntries;
     }
 
-    /** */
-    public void queryTransactionEntries(@Nullable Collection<QueryTxEntry> qryTxEntries) {
-        this.qryTxEntries = qryTxEntries;
-    }
-
     /** */
     public @Nullable Map<String, String> applicationAttributes() {
         return appAttrs;
     }
 
-    /** */
-    public void applicationAttributes(@Nullable Map<String, String> appAttrs) {
-        this.appAttrs = appAttrs;
-    }
-
     /** {@inheritDoc} */
     @Override public void prepareMarshal(GridCacheSharedContext<?, ?> ctx) throws IgniteCheckedException {
         if (paramsBytes == null && params != null)