http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/193d9b32/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryFailResponse.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryFailResponse.java b/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryFailResponse.java new file mode 100644 index 0000000..ba5855e --- /dev/null +++ b/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryFailResponse.java @@ -0,0 +1,46 @@ +/* @java.file.header */ + +/* _________ _____ __________________ _____ + * __ ____/___________(_)______ /__ ____/______ ____(_)_______ + * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \ + * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / / + * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/ + */ + +package org.gridgain.grid.kernal.processors.query.h2.twostep.messages; + +import java.io.*; + +/** + * Error message. + */ +public class GridQueryFailResponse implements Serializable { + /** */ + private long qryReqId; + + /** */ + private Throwable err; + + /** + * @param qryReqId Query request ID. + * @param err Error. + */ + public GridQueryFailResponse(long qryReqId, Throwable err) { + this.qryReqId = qryReqId; + this.err = err; + } + + /** + * @return Query request ID. + */ + public long queryRequestId() { + return qryReqId; + } + + /** + * @return Error. + */ + public Throwable error() { + return err; + } +}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/193d9b32/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryRequest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryRequest.java b/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryRequest.java new file mode 100644 index 0000000..7e2e9ad --- /dev/null +++ b/modules/indexing/src/main/java/org/gridgain/grid/kernal/processors/query/h2/twostep/messages/GridQueryRequest.java @@ -0,0 +1,61 @@ +/* @java.file.header */ + +/* _________ _____ __________________ _____ + * __ ____/___________(_)______ /__ ____/______ ____(_)_______ + * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \ + * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / / + * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/ + */ + +package org.gridgain.grid.kernal.processors.query.h2.twostep.messages; + +import org.gridgain.grid.kernal.processors.cache.query.*; + +import java.io.*; +import java.util.*; + +/** + * Query request. + */ +public class GridQueryRequest implements Serializable { + /** */ + private long reqId; + + /** */ + private int pageSize; + + /** */ + private Collection<GridCacheSqlQuery> qrys; + + /** + * @param reqId Request ID. + * @param pageSize Page size. + * @param qrys Queries. + */ + public GridQueryRequest(long reqId, int pageSize, Collection<GridCacheSqlQuery> qrys) { + this.reqId = reqId; + this.pageSize = pageSize; + this.qrys = qrys; + } + + /** + * @return Request ID. + */ + public long requestId() { + return reqId; + } + + /** + * @return Page size. + */ + public int pageSize() { + return pageSize; + } + + /** + * @return Queries. + */ + public Collection<GridCacheSqlQuery> queries() { + return qrys; + } +}
