Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package com.facebook.presto.server;
 
 
 
 import java.net.URI;
 import java.util.List;
 
 import static com.facebook.presto.server.ResourceUtil.assertRequest;
 import static com.facebook.presto.server.ResourceUtil.createSessionForRequest;
 import static com.google.common.base.Preconditions.checkNotNull;
 import static com.google.common.base.Strings.isNullOrEmpty;
 import static io.airlift.http.client.HttpUriBuilder.uriBuilderFrom;

Manage queries scheduled on this node
 
 @Path("/v1/query")
 public class QueryResource
 {
     private final QueryManager queryManager;
 
     @Inject
     public QueryResource(QueryManager queryManager)
     {
         this. = checkNotNull(queryManager"queryManager is null");
     }
 
     @GET
     public List<BasicQueryInfogetAllQueryInfo()
     {
     }
 
     private static List<BasicQueryInfoextractBasicQueryInfo(List<QueryInfoallQueryInfo)
     {
         ImmutableList.Builder<BasicQueryInfobasicQueryInfo = ImmutableList.builder();
         for (QueryInfo queryInfo : allQueryInfo) {
             basicQueryInfo.add(new BasicQueryInfo(queryInfo));
         }
         return basicQueryInfo.build();
     }
 
     @GET
     @Path("{queryId}")
     public Response getQueryInfo(@PathParam("queryId"QueryId queryId)
     {
         checkNotNull(queryId"queryId is null");
 
         try {
             QueryInfo queryInfo = .getQueryInfo(queryId);
             return Response.ok(queryInfo).build();
         }
         catch (NoSuchElementException e) {
             return Response.status(.).build();
         }
     }
 
     @POST
     public Response createQuery(
             String statement,
             @Context HttpServletRequest servletRequest,
             @Context UriInfo uriInfo)
     {
         assertRequest(!isNullOrEmpty(statement), "SQL statement is empty");
 
        Session session = createSessionForRequest(servletRequest);
        QueryInfo queryInfo = .createQuery(sessionstatement);
        URI pagesUri = uriBuilderFrom(uriInfo.getRequestUri()).appendPath(queryInfo.getQueryId().toString()).build();
        return Response.created(pagesUri).entity(queryInfo).build();
    }
    @DELETE
    @Path("{queryId}")
    public void cancelQuery(@PathParam("queryId"QueryId queryId)
    {
        checkNotNull(queryId"queryId is null");
        .cancelQuery(queryId);
    }
    @DELETE
    @Path("stage/{stageId}")
    public void cancelStage(@PathParam("stageId"StageId stageId)
    {
        checkNotNull(stageId"stageId is null");
        .cancelStage(stageId);
    }
New to GrepCode? Check out our FAQ X