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

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

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

JobConfiguration.getExtract介绍

[英][Pick one] Configures an extract 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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationExtract extractConfigurationPb = configurationPb.getExtract();
 this.sourceTable = TableId.fromPb(extractConfigurationPb.getSourceTable());
 this.destinationUris = extractConfigurationPb.getDestinationUris();
 this.printHeader = extractConfigurationPb.getPrintHeader();
 this.fieldDelimiter = extractConfigurationPb.getFieldDelimiter();
 this.format = extractConfigurationPb.getDestinationFormat();
 this.compression = extractConfigurationPb.getCompression();
}

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

@Test
public void testToPbAndFromPb() {
 assertNotNull(COPY_JOB.toPb().getConfiguration().getCopy());
 assertNull(COPY_JOB.toPb().getConfiguration().getExtract());
 assertNull(COPY_JOB.toPb().getConfiguration().getLoad());
 assertNull(COPY_JOB.toPb().getConfiguration().getQuery());
 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());
 assertNull(EXTRACT_JOB.toPb().getConfiguration().getQuery());
 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());
 assertNull(LOAD_JOB.toPb().getConfiguration().getQuery());
 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());
 assertNotNull(QUERY_JOB.toPb().getConfiguration().getQuery());

代码示例来源：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/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/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.gcloud/gcloud-java-bigquery

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationExtract extractConfigurationPb = configurationPb.getExtract();
 this.sourceTable = TableId.fromPb(extractConfigurationPb.getSourceTable());
 this.destinationUris = extractConfigurationPb.getDestinationUris();
 this.printHeader = extractConfigurationPb.getPrintHeader();
 this.fieldDelimiter = extractConfigurationPb.getFieldDelimiter();
 this.format = extractConfigurationPb.getDestinationFormat();
 this.compression = extractConfigurationPb.getCompression();
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationExtract extractConfigurationPb = configurationPb.getExtract();
 this.sourceTable = TableId.fromPb(extractConfigurationPb.getSourceTable());
 this.destinationUris = extractConfigurationPb.getDestinationUris();
 this.printHeader = extractConfigurationPb.getPrintHeader();
 this.fieldDelimiter = extractConfigurationPb.getFieldDelimiter();
 this.format = extractConfigurationPb.getDestinationFormat();
 this.compression = extractConfigurationPb.getCompression();
}

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

private Builder(com.google.api.services.bigquery.model.JobConfiguration configurationPb) {
 this();
 JobConfigurationExtract extractConfigurationPb = configurationPb.getExtract();
 this.sourceTable = TableId.fromPb(extractConfigurationPb.getSourceTable());
 this.destinationUris = extractConfigurationPb.getDestinationUris();
 this.printHeader = extractConfigurationPb.getPrintHeader();
 this.fieldDelimiter = extractConfigurationPb.getFieldDelimiter();
 this.format = extractConfigurationPb.getDestinationFormat();
 this.compression = extractConfigurationPb.getCompression();
}

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

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

JobConfiguration

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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