Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Drill, mail # dev - git commit: DRILL-164: Add QueryId return in UserResultListener so that REST api can use for external query management.


+
jacques@... 2013-11-13, 17:44
Copy link to this message
-
Re: git commit: DRILL-164: Add QueryId return in UserResultListener so that REST api can use for external query management.
Srihari Srinivasan 2013-11-14, 06:44
Cool! Thanks...
On Wed, Nov 13, 2013 at 11:14 PM, <[EMAIL PROTECTED]> wrote:

> Updated Branches:
>   refs/heads/master d17f48315 -> dc2e17308
>
>
> DRILL-164: Add QueryId return in UserResultListener so that REST api can
> use for external query management.
>
>
> Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
> Commit:
> http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/dc2e1730
> Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/dc2e1730
> Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/dc2e1730
>
> Branch: refs/heads/master
> Commit: dc2e17308e1be686e3422320c26249cbc8728047
> Parents: d17f483
> Author: Jacques Nadeau <[EMAIL PROTECTED]>
> Authored: Mon Nov 11 10:54:04 2013 -0800
> Committer: Jacques Nadeau <[EMAIL PROTECTED]>
> Committed: Mon Nov 11 10:54:04 2013 -0800
>
> ----------------------------------------------------------------------
>  .../java/org/apache/drill/exec/client/DrillClient.java  |  5 +++++
>  .../org/apache/drill/exec/client/QuerySubmitter.java    |  5 +++++
>  .../apache/drill/exec/rpc/user/QueryResultHandler.java  |  6 ++++++
>  .../apache/drill/exec/rpc/user/UserResultsListener.java |  7 ++-----
>  .../drill/exec/store/ParquetRecordReaderTest.java       | 12 +++++++-----
>  .../drill/exec/store/TestParquetPhysicalPlan.java       |  6 ++++++
>  .../exec/store/parquet/ParquetRecordReaderTest.java     |  5 +++++
>  .../org/apache/drill/sql/client/full/BatchListener.java |  5 +++++
>  8 files changed, 41 insertions(+), 10 deletions(-)
> ----------------------------------------------------------------------
>
>
>
> http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/dc2e1730/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java
> ----------------------------------------------------------------------
> diff --git
> a/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java
> b/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java
> index 4d6088d..8ee9042 100644
> ---
> a/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java
> +++
> b/exec/java-exec/src/main/java/org/apache/drill/exec/client/DrillClient.java
> @@ -37,6 +37,7 @@ import org.apache.drill.exec.coord.ClusterCoordinator;
>  import org.apache.drill.exec.coord.ZKClusterCoordinator;
>  import org.apache.drill.exec.memory.DirectBufferAllocator;
>  import org.apache.drill.exec.proto.CoordinationProtos.DrillbitEndpoint;
> +import org.apache.drill.exec.proto.UserBitShared.QueryId;
>  import org.apache.drill.exec.proto.UserProtos;
>  import org.apache.drill.exec.proto.UserProtos.QueryType;
>  import org.apache.drill.exec.rpc.*;
> @@ -231,6 +232,10 @@ public class DrillClient implements Closeable{
>          throw RpcException.mapException(t);
>        }
>      }
> +
> +    @Override
> +    public void queryIdArrived(QueryId queryId) {
> +    }
>    }
>
>    private class FutureHandler extends AbstractCheckedFuture<Void,
> RpcException> implements RpcConnectionHandler<ServerConnection>,
> DrillRpcFuture<Void>{
>
>
> http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/dc2e1730/exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java
> ----------------------------------------------------------------------
> diff --git
> a/exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java
> b/exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java
> index 554fad0..7adefdb 100644
> ---
> a/exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java
> +++
> b/exec/java-exec/src/main/java/org/apache/drill/exec/client/QuerySubmitter.java
> @@ -31,6 +31,7 @@ import org.apache.drill.common.config.DrillConfig;
>  import org.apache.drill.exec.coord.ClusterCoordinator;
>  import org.apache.drill.exec.coord.ZKClusterCoordinator;
>  import org.apache.drill.exec.exception.SchemaChangeException;
> +import org.apache.drill.exec.proto.UserBitShared.QueryId;