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

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

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

JobConfiguration.setCopy介绍

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

代码示例

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

@Override
com.google.api.services.bigquery.model.JobConfiguration toPb() {
 JobConfigurationTableCopy configurationPb = new JobConfigurationTableCopy();
 configurationPb.setDestinationTable(destinationTable.toPb());
 if (sourceTables.size() == 1) {
  configurationPb.setSourceTable(sourceTables.get(0).toPb());
 } else {
  configurationPb.setSourceTables(Lists.transform(sourceTables, TableId.TO_PB_FUNCTION));
 }
 if (createDisposition != null) {
  configurationPb.setCreateDisposition(createDisposition.toString());
 }
 if (writeDisposition != null) {
  configurationPb.setWriteDisposition(writeDisposition.toString());
 }
 if (destinationEncryptionConfiguration != null) {
  configurationPb.setDestinationEncryptionConfiguration(
    destinationEncryptionConfiguration.toPb());
 }
 return new com.google.api.services.bigquery.model.JobConfiguration().setCopy(configurationPb);
}

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

@Test
public void testIncomplete() {
 // https://github.com/googleapis/google-cloud-java/issues/2357
 com.google.api.services.bigquery.model.Job job =
   new com.google.api.services.bigquery.model.Job()
     .setStatistics(
       new com.google.api.services.bigquery.model.JobStatistics()
         .setCreationTime(1234L)
         .setStartTime(5678L));
 job.setConfiguration(
   new com.google.api.services.bigquery.model.JobConfiguration()
     .setCopy(new com.google.api.services.bigquery.model.JobConfigurationTableCopy()));
 assertThat(JobStatistics.fromPb(job)).isInstanceOf(CopyStatistics.class);
 job.setConfiguration(
   new com.google.api.services.bigquery.model.JobConfiguration()
     .setLoad(new com.google.api.services.bigquery.model.JobConfigurationLoad()));
 assertThat(JobStatistics.fromPb(job)).isInstanceOf(LoadStatistics.class);
 job.setConfiguration(
   new com.google.api.services.bigquery.model.JobConfiguration()
     .setExtract(new com.google.api.services.bigquery.model.JobConfigurationExtract()));
 assertThat(JobStatistics.fromPb(job)).isInstanceOf(ExtractStatistics.class);
 job.setConfiguration(
   new com.google.api.services.bigquery.model.JobConfiguration()
     .setQuery(new com.google.api.services.bigquery.model.JobConfigurationQuery()));
 assertThat(JobStatistics.fromPb(job)).isInstanceOf(QueryStatistics.class);
}

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

@Override
com.google.api.services.bigquery.model.JobConfiguration toPb() {
 JobConfigurationTableCopy configurationPb = new JobConfigurationTableCopy();
 configurationPb.setDestinationTable(destinationTable.toPb());
 if (sourceTables.size() == 1) {
  configurationPb.setSourceTable(sourceTables.get(0).toPb());
 } else {
  configurationPb.setSourceTables(Lists.transform(sourceTables, TableId.TO_PB_FUNCTION));
 }
 if (createDisposition != null) {
  configurationPb.setCreateDisposition(createDisposition.toString());
 }
 if (writeDisposition != null) {
  configurationPb.setWriteDisposition(writeDisposition.toString());
 }
 return new com.google.api.services.bigquery.model.JobConfiguration().setCopy(configurationPb);
}

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

/**
 * {@inheritDoc}
 *
 * <p>Tries executing the RPC for at most {@code MAX_RPC_RETRIES} times until it succeeds.
 *
 * @throws IOException if it exceeds {@code MAX_RPC_RETRIES} attempts.
 */
@Override
public void startCopyJob(JobReference jobRef, JobConfigurationTableCopy copyConfig)
  throws IOException, InterruptedException {
 Job job =
   new Job()
     .setJobReference(jobRef)
     .setConfiguration(new JobConfiguration().setCopy(copyConfig));
 startJob(job, errorExtractor, client);
}

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

@Override
com.google.api.services.bigquery.model.JobConfiguration toPb() {
 JobConfigurationTableCopy configurationPb = new JobConfigurationTableCopy();
 configurationPb.setDestinationTable(destinationTable.toPb());
 if (sourceTables.size() == 1) {
  configurationPb.setSourceTable(sourceTables.get(0).toPb());
 } else {
  configurationPb.setSourceTables(Lists.transform(sourceTables, TableId.TO_PB_FUNCTION));
 }
 if (createDisposition != null) {
  configurationPb.setCreateDisposition(createDisposition.toString());
 }
 if (writeDisposition != null) {
  configurationPb.setWriteDisposition(writeDisposition.toString());
 }
 return new com.google.api.services.bigquery.model.JobConfiguration().setCopy(configurationPb);
}

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

@Override
com.google.api.services.bigquery.model.JobConfiguration toPb() {
 JobConfigurationTableCopy configurationPb = new JobConfigurationTableCopy();
 configurationPb.setDestinationTable(destinationTable.toPb());
 if (sourceTables.size() == 1) {
  configurationPb.setSourceTable(sourceTables.get(0).toPb());
 } else {
  configurationPb.setSourceTables(Lists.transform(sourceTables, TableId.TO_PB_FUNCTION));
 }
 if (createDisposition != null) {
  configurationPb.setCreateDisposition(createDisposition.toString());
 }
 if (writeDisposition != null) {
  configurationPb.setWriteDisposition(writeDisposition.toString());
 }
 if (destinationEncryptionConfiguration != null) {
  configurationPb.setDestinationEncryptionConfiguration(
    destinationEncryptionConfiguration.toPb());
 }
 return new com.google.api.services.bigquery.model.JobConfiguration().setCopy(configurationPb);
}

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

@Override
public void startCopyJob(JobReference jobRef, JobConfigurationTableCopy copyConfig)
  throws IOException {
 synchronized (allJobs) {
  verifyUniqueJobId(jobRef.getJobId());
  Job job = new Job();
  job.setJobReference(jobRef);
  job.setConfiguration(new JobConfiguration().setCopy(copyConfig));
  job.setKind(" bigquery#job");
  job.setStatus(new JobStatus().setState("PENDING"));
  allJobs.put(jobRef.getProjectId(), jobRef.getJobId(), new JobInfo(job));
 }
}

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

config.setCopy(copyTableConfig);

相关文章