import com.google.api.services.bigquery.Bigquery.Jobs.GetQueryResults; //导入依赖的package包/类
public static Iterator<GetQueryResultsResponse> run(final String queryString,
  final String projId, final long wTime, final long maxRows, boolean useLegacySql)
    throws IOException {
  try {
    logger.info("Use legacy sql: {}", useLegacySql);
    QueryResponse query;
    query = service
        .jobs()
        .query(
            projId,
            new QueryRequest().setTimeoutMs(wTime)
                .setUseLegacySql(useLegacySql).setQuery(queryString)
                .setMaxResults(maxRows)).execute();
    jobId = query.getJobReference().getJobId();
    projectId = query.getJobReference().getProjectId();
    GetQueryResults getRequest = service.jobs().getQueryResults(
        projectId,
        jobId);
    return getPages(getRequest);
  } catch (IOException ex) {
    throw ex;
  }
}
 

import com.google.api.services.bigquery.Bigquery.Jobs.GetQueryResults; //导入依赖的package包/类
public static Iterator<GetQueryResultsResponse> run(String projectId, 
    String queryString, 
    long waitTime) throws IOException{
  Bigquery bigquery = BigqueryServiceFactory.getService();
  //Wait until query is done with 10 second timeout, at most 5 retries on error
  QueryResponse query = bigquery.jobs().query(
      projectId,
      new QueryRequest().setTimeoutMs(waitTime).setQuery(queryString)).execute();
  
  //Make a request to get the results of the query 
  //(timeout is zero since job should be complete)
  
  GetQueryResults getRequest = bigquery.jobs().getQueryResults(
      query.getJobReference().getProjectId(),
      query.getJobReference().getJobId());
  
  
  return getPages(getRequest);
}
 

import com.google.api.services.bigquery.Bigquery.Jobs.GetQueryResults; //导入依赖的package包/类
public static Iterator<GetQueryResultsResponse> run(String projectId,
    String queryString,
    boolean batch, 
    long waitTime) 
    throws IOException, InterruptedException{
  
  Bigquery bigquery = BigqueryServiceFactory.getService();

  Job query = asyncQuery(bigquery, projectId, queryString, batch);
  Bigquery.Jobs.Get getRequest = bigquery.jobs().get(
      projectId, query.getJobReference().getJobId());
  
  //Poll every waitTime milliseconds, 
  //retrying at most retries times if there are errors
  pollJob(getRequest, waitTime);

  GetQueryResults resultsRequest = bigquery.jobs().getQueryResults(
      projectId, query.getJobReference().getJobId());
  
   return getPages(resultsRequest);
}