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

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

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

JobConfiguration.getCopy介绍

[英][Pick one] Copies a table.
[中][选择一个]复制一张表。

代码示例

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

@SuppressWarnings("unchecked")
 static <T extends JobConfiguration> T fromPb(
   com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
  if (configurationPb.getCopy() != null) {
   return (T) CopyJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getExtract() != null) {
   return (T) ExtractJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getLoad() != null) {
   return (T) LoadJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getQuery() != null) {
   return (T) QueryJobConfiguration.fromPb(configurationPb);
  } else {
   // never reached
   throw new IllegalArgumentException("Job configuration is not supported");
  }
 }
}

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

@SuppressWarnings("unchecked")
 static <T extends JobStatistics> T fromPb(com.google.api.services.bigquery.model.Job jobPb) {
  JobConfiguration jobConfigPb = jobPb.getConfiguration();
  com.google.api.services.bigquery.model.JobStatistics statisticPb = jobPb.getStatistics();
  if (jobConfigPb.getLoad() != null) {
   return (T) LoadStatistics.fromPb(statisticPb);
  } else if (jobConfigPb.getExtract() != null) {
   return (T) ExtractStatistics.fromPb(statisticPb);
  } else if (jobConfigPb.getQuery() != null) {
   return (T) QueryStatistics.fromPb(statisticPb);
  } else if (jobConfigPb.getCopy() != null) {
   return (T) CopyStatistics.fromPb(statisticPb);
  } else {
   throw new IllegalArgumentException("unknown job configuration: " + jobConfigPb);
  }
 }
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationTableCopy copyConfigurationPb = configurationPb.getCopy();
 this.destinationTable = TableId.fromPb(copyConfigurationPb.getDestinationTable());
 if (copyConfigurationPb.getSourceTables() != null) {
  this.sourceTables =
    Lists.transform(copyConfigurationPb.getSourceTables(), TableId.FROM_PB_FUNCTION);
 } else {
  this.sourceTables = ImmutableList.of(TableId.fromPb(copyConfigurationPb.getSourceTable()));
 }
 if (copyConfigurationPb.getCreateDisposition() != null) {
  this.createDisposition =
    JobInfo.CreateDisposition.valueOf(copyConfigurationPb.getCreateDisposition());
 }
 if (copyConfigurationPb.getWriteDisposition() != null) {
  this.writeDisposition =
    JobInfo.WriteDisposition.valueOf(copyConfigurationPb.getWriteDisposition());
 }
 if (copyConfigurationPb.getDestinationEncryptionConfiguration() != null) {
  this.destinationEncryptionConfiguration =
    new EncryptionConfiguration.Builder(
        copyConfigurationPb.getDestinationEncryptionConfiguration())
      .build();
 }
}

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

@Test
public void testToPbAndFromPb() {
 assertNotNull(COPY_JOB_CONFIGURATION.toPb().getCopy());
 assertNull(COPY_JOB_CONFIGURATION.toPb().getExtract());
 assertNull(COPY_JOB_CONFIGURATION.toPb().getLoad());
 assertNull(COPY_JOB_CONFIGURATION.toPb().getQuery());
 assertNull(COPY_JOB_CONFIGURATION.toPb().getCopy().getSourceTables());
 assertNull(COPY_JOB_CONFIGURATION_MULTIPLE_TABLES.toPb().getCopy().getSourceTable());
 compareCopyJobConfiguration(
   COPY_JOB_CONFIGURATION, CopyJobConfiguration.fromPb(COPY_JOB_CONFIGURATION.toPb()));
 compareCopyJobConfiguration(
   COPY_JOB_CONFIGURATION_MULTIPLE_TABLES,
   CopyJobConfiguration.fromPb(COPY_JOB_CONFIGURATION_MULTIPLE_TABLES.toPb()));
 CopyJobConfiguration jobConfiguration =
   CopyJobConfiguration.of(DESTINATION_TABLE, SOURCE_TABLES);
 compareCopyJobConfiguration(
   jobConfiguration, CopyJobConfiguration.fromPb(jobConfiguration.toPb()));
}

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

@Test
public void testToPbAndFromPb() {
 assertNotNull(QUERY_JOB_CONFIGURATION.toPb().getQuery());
 assertNull(QUERY_JOB_CONFIGURATION.toPb().getExtract());
 assertNull(QUERY_JOB_CONFIGURATION.toPb().getCopy());
 assertNull(QUERY_JOB_CONFIGURATION.toPb().getLoad());
 compareQueryJobConfiguration(
   QUERY_JOB_CONFIGURATION, QueryJobConfiguration.fromPb(QUERY_JOB_CONFIGURATION.toPb()));
 QueryJobConfiguration job = QueryJobConfiguration.of(QUERY);
 compareQueryJobConfiguration(job, QueryJobConfiguration.fromPb(job.toPb()));
}

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

@Test
public void testToPbAndFromPb() {
 assertNotNull(EXTRACT_CONFIGURATION.toPb().getExtract());
 assertNull(EXTRACT_CONFIGURATION.toPb().getCopy());
 assertNull(EXTRACT_CONFIGURATION.toPb().getLoad());
 assertNull(EXTRACT_CONFIGURATION.toPb().getQuery());
 compareExtractJobConfiguration(
   EXTRACT_CONFIGURATION, ExtractJobConfiguration.fromPb(EXTRACT_CONFIGURATION.toPb()));
 compareExtractJobConfiguration(
   EXTRACT_CONFIGURATION_ONE_URI,
   ExtractJobConfiguration.fromPb(EXTRACT_CONFIGURATION_ONE_URI.toPb()));
 ExtractJobConfiguration job = ExtractJobConfiguration.of(TABLE_ID, DESTINATION_URIS);
 compareExtractJobConfiguration(job, ExtractJobConfiguration.fromPb(job.toPb()));
}

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

@Test
public void testToPbAndFromPb() {
 assertNotNull(COPY_JOB.toPb().getConfiguration().getCopy());
 assertNull(COPY_JOB.toPb().getConfiguration().getExtract());
 assertNull(COPY_JOB.toPb().getConfiguration().getLoad());
 compareJobInfo(COPY_JOB, JobInfo.fromPb(COPY_JOB.toPb()));
 assertTrue(JobInfo.fromPb(COPY_JOB.toPb()).getConfiguration() instanceof CopyJobConfiguration);
 assertNull(EXTRACT_JOB.toPb().getConfiguration().getCopy());
 assertNotNull(EXTRACT_JOB.toPb().getConfiguration().getExtract());
 assertNull(EXTRACT_JOB.toPb().getConfiguration().getLoad());
   JobInfo.fromPb(EXTRACT_JOB.toPb()).getConfiguration() instanceof ExtractJobConfiguration);
 assertTrue(JobInfo.fromPb(EXTRACT_JOB.toPb()).getStatistics() instanceof ExtractStatistics);
 assertNull(LOAD_JOB.toPb().getConfiguration().getCopy());
 assertNull(LOAD_JOB.toPb().getConfiguration().getExtract());
 assertNotNull(LOAD_JOB.toPb().getConfiguration().getLoad());
 assertTrue(JobInfo.fromPb(LOAD_JOB.toPb()).getConfiguration() instanceof LoadJobConfiguration);
 assertTrue(JobInfo.fromPb(LOAD_JOB.toPb()).getStatistics() instanceof LoadStatistics);
 assertNull(QUERY_JOB.toPb().getConfiguration().getCopy());
 assertNull(QUERY_JOB.toPb().getConfiguration().getExtract());
 assertNull(QUERY_JOB.toPb().getConfiguration().getLoad());

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

@SuppressWarnings("unchecked")
 static <T extends JobConfiguration> T fromPb(
   com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
  if (configurationPb.getCopy() != null) {
   return (T) CopyJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getExtract() != null) {
   return (T) ExtractJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getLoad() != null) {
   return (T) LoadJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getQuery() != null) {
   return (T) QueryJobConfiguration.fromPb(configurationPb);
  } else {
   // never reached
   throw new IllegalArgumentException("Job configuration is not supported");
  }
 }
}

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

@SuppressWarnings("unchecked")
 static <T extends JobConfiguration> T fromPb(
   com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
  if (configurationPb.getCopy() != null) {
   return (T) CopyJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getExtract() != null) {
   return (T) ExtractJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getLoad() != null) {
   return (T) LoadJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getQuery() != null) {
   return (T) QueryJobConfiguration.fromPb(configurationPb);
  } else {
   // never reached
   throw new IllegalArgumentException("Job configuration is not supported");
  }
 }
}

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

@SuppressWarnings("unchecked")
 static <T extends JobConfiguration> T fromPb(
   com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
  if (configurationPb.getCopy() != null) {
   return (T) CopyJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getExtract() != null) {
   return (T) ExtractJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getLoad() != null) {
   return (T) LoadJobConfiguration.fromPb(configurationPb);
  } else if (configurationPb.getQuery() != null) {
   return (T) QueryJobConfiguration.fromPb(configurationPb);
  } else {
   // never reached
   throw new IllegalArgumentException("Job configuration is not supported");
  }
 }
}

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

@SuppressWarnings("unchecked")
 static <T extends JobStatistics> T fromPb(com.google.api.services.bigquery.model.Job jobPb) {
  JobConfiguration jobConfigPb = jobPb.getConfiguration();
  com.google.api.services.bigquery.model.JobStatistics statisticPb = jobPb.getStatistics();
  if (jobConfigPb.getLoad() != null) {
   return (T) LoadStatistics.fromPb(statisticPb);
  } else if (jobConfigPb.getExtract() != null) {
   return (T) ExtractStatistics.fromPb(statisticPb);
  } else if (jobConfigPb.getQuery() != null) {
   return (T) QueryStatistics.fromPb(statisticPb);
  } else if (jobConfigPb.getCopy() != null) {
   return (T) CopyStatistics.fromPb(statisticPb);
  } else {
   throw new IllegalArgumentException("unknown job configuration: " + jobConfigPb);
  }
 }
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationTableCopy copyConfigurationPb = configurationPb.getCopy();
 this.destinationTable = TableId.fromPb(copyConfigurationPb.getDestinationTable());
 if (copyConfigurationPb.getSourceTables() != null) {
  this.sourceTables =
    Lists.transform(copyConfigurationPb.getSourceTables(), TableId.FROM_PB_FUNCTION);
 } else {
  this.sourceTables = ImmutableList.of(TableId.fromPb(copyConfigurationPb.getSourceTable()));
 }
 if (copyConfigurationPb.getCreateDisposition() != null) {
  this.createDisposition =
    JobInfo.CreateDisposition.valueOf(copyConfigurationPb.getCreateDisposition());
 }
 if (copyConfigurationPb.getWriteDisposition() != null) {
  this.writeDisposition = JobInfo.WriteDisposition.valueOf(
    copyConfigurationPb.getWriteDisposition());
 }
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationTableCopy copyConfigurationPb = configurationPb.getCopy();
 this.destinationTable = TableId.fromPb(copyConfigurationPb.getDestinationTable());
 if (copyConfigurationPb.getSourceTables() != null) {
  this.sourceTables =
    Lists.transform(copyConfigurationPb.getSourceTables(), TableId.FROM_PB_FUNCTION);
 } else {
  this.sourceTables = ImmutableList.of(TableId.fromPb(copyConfigurationPb.getSourceTable()));
 }
 if (copyConfigurationPb.getCreateDisposition() != null) {
  this.createDisposition =
    JobInfo.CreateDisposition.valueOf(copyConfigurationPb.getCreateDisposition());
 }
 if (copyConfigurationPb.getWriteDisposition() != null) {
  this.writeDisposition = JobInfo.WriteDisposition.valueOf(
    copyConfigurationPb.getWriteDisposition());
 }
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationTableCopy copyConfigurationPb = configurationPb.getCopy();
 this.destinationTable = TableId.fromPb(copyConfigurationPb.getDestinationTable());
 if (copyConfigurationPb.getSourceTables() != null) {
  this.sourceTables =
    Lists.transform(copyConfigurationPb.getSourceTables(), TableId.FROM_PB_FUNCTION);
 } else {
  this.sourceTables = ImmutableList.of(TableId.fromPb(copyConfigurationPb.getSourceTable()));
 }
 if (copyConfigurationPb.getCreateDisposition() != null) {
  this.createDisposition =
    JobInfo.CreateDisposition.valueOf(copyConfigurationPb.getCreateDisposition());
 }
 if (copyConfigurationPb.getWriteDisposition() != null) {
  this.writeDisposition =
    JobInfo.WriteDisposition.valueOf(copyConfigurationPb.getWriteDisposition());
 }
 if (copyConfigurationPb.getDestinationEncryptionConfiguration() != null) {
  this.destinationEncryptionConfiguration =
    new EncryptionConfiguration.Builder(
        copyConfigurationPb.getDestinationEncryptionConfiguration())
      .build();
 }
}

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

private JobStatus runJob(Job job) throws InterruptedException, IOException {
 if (job.getConfiguration().getLoad() != null) {
  return runLoadJob(job.getJobReference(), job.getConfiguration().getLoad());
 } else if (job.getConfiguration().getCopy() != null) {
  return runCopyJob(job.getConfiguration().getCopy());
 } else if (job.getConfiguration().getExtract() != null) {
  return runExtractJob(job, job.getConfiguration().getExtract());
 } else if (job.getConfiguration().getQuery() != null) {
  return runQueryJob(job.getConfiguration().getQuery());
 }
 return new JobStatus().setState("DONE");
}

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

JobConfiguration

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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