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

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

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

JobConfiguration.getLoad介绍

[英][Pick one] Configures a load job.
[中][选择一个]配置加载作业。

代码示例

代码示例来源：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

@Test
public void testToPbAndFromPb() {
 assertNull(LOAD_CONFIGURATION_CSV.toPb().getLoad().getSourceUris());
 compareLoadConfiguration(
   LOAD_CONFIGURATION_CSV, WriteChannelConfiguration.fromPb(LOAD_CONFIGURATION_CSV.toPb()));
 WriteChannelConfiguration configuration = WriteChannelConfiguration.of(TABLE_ID);
 compareLoadConfiguration(configuration, WriteChannelConfiguration.fromPb(configuration.toPb()));
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {
 this.projectionFields = loadConfigurationPb.getProjectionFields();
 if (loadConfigurationPb.getSourceUris() != null) {
  this.sourceUris = ImmutableList.copyOf(configurationPb.getLoad().getSourceUris());

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {
  this.destinationEncryptionConfiguration =
    new EncryptionConfiguration.Builder(
        configurationPb.getLoad().getDestinationEncryptionConfiguration())
      .build();

代码示例来源：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_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

assertNotNull(COPY_JOB.toPb().getConfiguration().getCopy());
assertNull(COPY_JOB.toPb().getConfiguration().getExtract());
assertNull(COPY_JOB.toPb().getConfiguration().getLoad());
assertNull(COPY_JOB.toPb().getConfiguration().getQuery());
assertEquals(COPY_JOB_STATISTICS, JobStatistics.fromPb(COPY_JOB.toPb()));
assertNull(EXTRACT_JOB.toPb().getConfiguration().getCopy());
assertNotNull(EXTRACT_JOB.toPb().getConfiguration().getExtract());
assertNull(EXTRACT_JOB.toPb().getConfiguration().getLoad());
assertNull(EXTRACT_JOB.toPb().getConfiguration().getQuery());
assertEquals(EXTRACT_JOB_STATISTICS, JobStatistics.fromPb(EXTRACT_JOB.toPb()));
assertNull(LOAD_JOB.toPb().getConfiguration().getCopy());
assertNull(LOAD_JOB.toPb().getConfiguration().getExtract());
assertNotNull(LOAD_JOB.toPb().getConfiguration().getLoad());
assertNull(LOAD_JOB.toPb().getConfiguration().getQuery());
assertEquals(LOAD_JOB_STATISTICS, JobStatistics.fromPb(LOAD_JOB.toPb()));
assertNull(QUERY_JOB.toPb().getConfiguration().getCopy());
assertNull(QUERY_JOB.toPb().getConfiguration().getExtract());
assertNull(QUERY_JOB.toPb().getConfiguration().getLoad());
assertNotNull(QUERY_JOB.toPb().getConfiguration().getQuery());
assertEquals(QUERY_JOB_STATISTICS, JobStatistics.fromPb(QUERY_JOB.toPb()));

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

static String jobToPrettyString(@Nullable Job job) throws IOException {
 if (job != null && job.getConfiguration().getLoad() != null) {
  // Removing schema and sourceUris from error messages for load jobs since these fields can be
  // quite long and error message might not be displayed properly in runner specific logs.
  job = job.clone();
  job.getConfiguration().getLoad().setSchema(null);
  job.getConfiguration().getLoad().setSourceUris(null);
 }
 return job == null ? "null" : job.toPrettyString();
}

代码示例来源：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 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: 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");
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {
 this.projectionFields = loadConfigurationPb.getProjectionFields();
 if (loadConfigurationPb.getSourceUris() != null) {
  this.sourceUris = ImmutableList.copyOf(configurationPb.getLoad().getSourceUris());

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {
 this.projectionFields = loadConfigurationPb.getProjectionFields();
 if (loadConfigurationPb.getSourceUris() != null) {
  this.sourceUris = ImmutableList.copyOf(configurationPb.getLoad().getSourceUris());

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {
  this.destinationEncryptionConfiguration =
    new EncryptionConfiguration.Builder(
        configurationPb.getLoad().getDestinationEncryptionConfiguration())
      .build();

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 JobConfigurationLoad loadConfigurationPb = configurationPb.getLoad();
 this.destinationTable = TableId.fromPb(loadConfigurationPb.getDestinationTable());
 if (loadConfigurationPb.getCreateDisposition() != null) {

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

JobConfiguration

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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