com.google.api.services.bigquery.model.Job.getStatus()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(148)

本文整理了Java中com.google.api.services.bigquery.model.Job.getStatus()方法的一些代码示例，展示了Job.getStatus()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Job.getStatus()方法的具体详情如下：
包路径：com.google.api.services.bigquery.model.Job
类名称：Job
方法名：getStatus

Job.getStatus介绍

[英][Output-only] The status of this job. Examine this value when polling an asynchronous job to see if the job is complete.
[中][仅输出]此作业的状态。在轮询异步作业以查看作业是否完成时，请检查此值。

代码示例

代码示例来源：origin: googleapis/google-cloud-java

BuilderImpl(Job jobPb) {
 this.etag = jobPb.getEtag();
 this.generatedId = jobPb.getId();
 if (jobPb.getJobReference() != null) {
  this.jobId = JobId.fromPb(jobPb.getJobReference());
 }
 this.selfLink = jobPb.getSelfLink();
 if (jobPb.getStatus() != null) {
  this.status = JobStatus.fromPb(jobPb.getStatus());
 }
 if (jobPb.getStatistics() != null) {
  this.statistics = JobStatistics.fromPb(jobPb);
 }
 this.userEmail = jobPb.getUserEmail();
 if (jobPb.getConfiguration() != null) {
  this.configuration = JobConfiguration.fromPb(jobPb.getConfiguration());
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

static Status parseStatus(@Nullable Job job) {
 if (job == null) {
  return Status.UNKNOWN;
 }
 JobStatus status = job.getStatus();
 if (status.getErrorResult() != null) {
  return Status.FAILED;
 } else if (status.getErrors() != null && !status.getErrors().isEmpty()) {
  return Status.FAILED;
 } else {
  return Status.SUCCEEDED;
 }
}

代码示例来源：origin: googlearchive/bigquery-samples-java

/**
 * Polls the status of a BigQuery job, returns Job reference if "Done"
 *
 * @param bigquery  an authorized BigQuery client
 * @param projectId a string containing the current project ID
 * @param jobId     a reference to an inserted query Job
 * @return a reference to the completed Job
 * @throws IOException
 * @throws InterruptedException
 */
private static Job checkQueryResults(Bigquery bigquery, String projectId, JobReference jobId)
  throws IOException, InterruptedException {
 // Variables to keep track of total query time
 long startTime = System.currentTimeMillis();
 long elapsedTime;
 while (true) {
  Job pollJob = bigquery.jobs().get(projectId, jobId.getJobId()).execute();
  elapsedTime = System.currentTimeMillis() - startTime;
  System.out.format("Job status (%dms) %s: %s\n", elapsedTime,
    jobId.getJobId(), pollJob.getStatus().getState());
  if (pollJob.getStatus().getState().equals("DONE")) {
   return pollJob;
  }
  // Pause execution for one second before polling job status again, to
  // reduce unnecessary calls to the BigQUery API and lower overall
  // application bandwidth.
  Thread.sleep(1000);
 }
}
// [END start_query]

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

"Load job {} finished in unknown state: {}: {}",
  currentJobId,
  job.getStatus(),
  shouldRetry() ? "will retry" : "will not retry");
return false;
  oldJobId,
  shouldRetry() ? "will retry" : "will not retry",
  job.getStatus(),
  currentJobId);
return false;
  String.format(
    "Unexpected status [%s] of load job: %s.",
    job.getStatus(), BigQueryHelpers.jobToPrettyString(job)));

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

continue;
JobStatus status = job.getStatus();
if (status == null) {
 LOG.info("Still waiting for BigQuery job {} to enter pending state", jobRef);

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

JobStatus jobStatus = loadJob.getStatus();
if (jobStatus == null) {
 LOG.info("job status for {} not found, so retrying with that job id", jobId);

代码示例来源：origin: com.google.cloud.bigdataoss/bigquery-connector

logger.atFine().log(
  "Job status (%s ms) %s: %s",
  elapsedTime, jobReference.getJobId(), pollJob.getStatus().getState());
if (pollJob.getStatus().getState().equals("DONE")) {
 notDone = false;
 if (pollJob.getStatus().getErrorResult() != null) {
  throw new IOException(
    "Error during BigQuery job execution: " + pollJob.getStatus().getErrorResult());

代码示例来源：origin: com.google.gcloud/gcloud-java-bigquery

BuilderImpl(Job jobPb) {
 this.etag = jobPb.getEtag();
 this.generatedId = jobPb.getId();
 if (jobPb.getJobReference() != null) {
  this.jobId = JobId.fromPb(jobPb.getJobReference());
 }
 this.selfLink = jobPb.getSelfLink();
 if (jobPb.getStatus() != null) {
  this.status = JobStatus.fromPb(jobPb.getStatus());
 }
 if (jobPb.getStatistics() != null) {
  this.statistics = JobStatistics.fromPb(jobPb.getStatistics());
 }
 this.userEmail = jobPb.getUserEmail();
 this.configuration = JobConfiguration.fromPb(jobPb.getConfiguration());
}

代码示例来源：origin: com.google.cloud/gcloud-java-bigquery

BuilderImpl(Job jobPb) {
 this.etag = jobPb.getEtag();
 this.generatedId = jobPb.getId();
 if (jobPb.getJobReference() != null) {
  this.jobId = JobId.fromPb(jobPb.getJobReference());
 }
 this.selfLink = jobPb.getSelfLink();
 if (jobPb.getStatus() != null) {
  this.status = JobStatus.fromPb(jobPb.getStatus());
 }
 if (jobPb.getStatistics() != null) {
  this.statistics = JobStatistics.fromPb(jobPb.getStatistics());
 }
 this.userEmail = jobPb.getUserEmail();
 this.configuration = JobConfiguration.fromPb(jobPb.getConfiguration());
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

private List<ResourceId> executeExtract(
  String jobId,
  TableReference table,
  JobService jobService,
  String executingProject,
  String extractDestinationDir,
  String bqLocation)
  throws InterruptedException, IOException {
 JobReference jobRef =
   new JobReference().setProjectId(executingProject).setLocation(bqLocation).setJobId(jobId);
 String destinationUri = BigQueryIO.getExtractDestinationUri(extractDestinationDir);
 JobConfigurationExtract extract =
   new JobConfigurationExtract()
     .setSourceTable(table)
     .setDestinationFormat("AVRO")
     .setDestinationUris(ImmutableList.of(destinationUri));
 LOG.info("Starting BigQuery extract job: {}", jobId);
 jobService.startExtractJob(jobRef, extract);
 Job extractJob = jobService.pollJob(jobRef, JOB_POLL_MAX_RETRIES);
 if (BigQueryHelpers.parseStatus(extractJob) != Status.SUCCEEDED) {
  throw new IOException(
    String.format(
      "Extract job %s failed, status: %s.",
      extractJob.getJobReference().getJobId(),
      BigQueryHelpers.statusToPrettyString(extractJob.getStatus())));
 }
 LOG.info("BigQuery extract job completed: {}", jobId);
 return BigQueryIO.getExtractFilePaths(extractDestinationDir, extractJob);
}

代码示例来源：origin: com.google.cloud/google-cloud-bigquery

BuilderImpl(Job jobPb) {
 this.etag = jobPb.getEtag();
 this.generatedId = jobPb.getId();
 if (jobPb.getJobReference() != null) {
  this.jobId = JobId.fromPb(jobPb.getJobReference());
 }
 this.selfLink = jobPb.getSelfLink();
 if (jobPb.getStatus() != null) {
  this.status = JobStatus.fromPb(jobPb.getStatus());
 }
 if (jobPb.getStatistics() != null) {
  this.statistics = JobStatistics.fromPb(jobPb);
 }
 this.userEmail = jobPb.getUserEmail();
 if (jobPb.getConfiguration() != null) {
  this.configuration = JobConfiguration.fromPb(jobPb.getConfiguration());
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

String.format(
  "Query job %s failed, status: %s.",
  queryJobId, BigQueryHelpers.statusToPrettyString(job.getStatus())));

代码示例来源：origin: io.digdag/digdag-standards

JobStatus status = job.getStatus();
      switch (status.getState()) {
        case "DONE":
JobStatus status = completed.getStatus();
if (status.getErrorResult() != null) {

代码示例来源：origin: com.spotify/scio-bigquery

String.format("Error when trying to get status of the job for query %s.",
    queryConfig.toPrettyString()));
JobStatus status = pollJob.getStatus();
if (status.getState().equals("DONE")) {

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

if (!"FAILED".equals(job.job.getStatus().getState())) {
 if (numFailures < numFailuresExpected) {
  ++numFailures;
  job.job.getStatus().setState("RUNNING");
 } else if (job.getJobCount == 2 * GET_JOBS_TRANSITION_INTERVAL + 1) {
  job.job.setStatus(runJob(job.job));
  .getStatus()
  .setState("FAILED")
  .setErrorResult(

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

@Override
public Job pollJob(JobReference jobRef, int maxAttempts) throws InterruptedException {
 BackOff backoff =
   BackOffAdapter.toGcpBackOff(
     FluentBackoff.DEFAULT
       .withMaxRetries(maxAttempts)
       .withInitialBackoff(Duration.millis(10))
       .withMaxBackoff(Duration.standardSeconds(1))
       .backoff());
 Sleeper sleeper = Sleeper.DEFAULT;
 try {
  do {
   Job job = getJob(jobRef);
   if (job != null) {
    JobStatus status = job.getStatus();
    if (status != null
      && ("DONE".equals(status.getState()) || "FAILED".equals(status.getState()))) {
     return job;
    }
   }
  } while (BackOffUtils.next(sleeper, backoff));
 } catch (IOException e) {
  return null;
 }
 return null;
}

内容来源于网络，如有侵权，请联系作者删除！

Job

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com