BigQuery java api线程安全吗？
BigQuery Java API是Google Cloud提供的用于与BigQuery进行交互的Java开发工具包。关于其线程安全性，根据官方文档，BigQuery Java API是线程安全的，可以在多线程环境下使用。
线程安全意味着多个线程可以同时访问和使用API的各种功能，而不会导致数据损坏或不一致的情况。在多线程应用程序中，可以使用BigQuery Java API来执行并发的查询、插入数据、管理表格等操作，而无需担心线程冲突或数据竞争的问题。
使用BigQuery Java API时，可以创建多个BigQuery客户端实例，并在多个线程中共享这些实例。每个线程都可以独立地使用这些实例来执行查询或其他操作，而不会相互干扰。这使得开发人员能够更好地利用多核处理器和并行计算能力，提高应用程序的性能和吞吐量。
总结起来，BigQuery Java API是线程安全的，可以在多线程环境下使用。开发人员可以放心地在多个线程中使用API的各种功能，以实现并发的数据处理和查询操作。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云数据库 BigQuery：https://cloud.tencent.com/product/bigquery
相关·内容
我想在我们的项目中使用google java api‘com.google.cloud: BigQuery -cloud-bigquery’。我正在创建这样的服务实例 BigQuery bq =
BigQueryOptions.newBuilder()
.setCredentials(credentials)
.build()
.getService(); 我是否应该将此com.google.cloud.bigquery.BigQuery实例存储在应用程序中的某个位置，并在每次调用时重用它？它是线程安全的
浏览 16提问于2019-02-27得票数 0
回答已采纳
1回答
我在Google的git存储库中找到了关于bigquery插入的一些示例代码。
如果您看到这个app.yaml，它说这段代码应该是线程安全的，但是如果我正在查看客户端库文档()，那么它不应该是线程安全的。我现在有点困惑，我的下面的代码是否线程安全？它运行在应用程序引擎标准env上。
import pprint
from googleapiclient.discovery import build
from oauth2client.client import GoogleCredentials
credentials = GoogleCredentials.get_applicatio
浏览 4提问于2016-06-14得票数 2
回答已采纳
我正在为google云存储和大查询创建默认连接：
BigQueryOptions
.getDefaultInstance()
.getService()
和
StorageOptions
.getDefaultInstance()
.getService()
我正在使用这些库：
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-storage</artifactId>
<version>1.5
浏览 0提问于2020-01-31得票数 0
到BQ 的流数据
我可以问为什么数据集中需要BigQuery Metadata Viewer访问吗？(尽管目的地传说已经存在)
仅使用表级的BigQuery数据编辑器，就会出现以下错误：google.api_core.exceptions.Forbidden: 403 POST https://bigquery.googleapis.com/bigquery/v2/projects/PROJECT/datasets/DATASET/tables/TABLE/insertAll: Access Denied: Dataset PROJECT:DATASET: User does not have
浏览 3提问于2020-10-31得票数 0
回答已采纳
当我使用ApacheBeamSDKforJava2.29.0将数据插入Bigauqery时，我正在断断续续地处理数据流作业中的内存问题。
这是堆栈跟踪
Error message from worker: java.lang.RuntimeException: java.lang.OutOfMemoryError: unable to create native thread: possibly out of memory or process/resource limits reached
org.apache.beam.sdk.io.gcp.bigquery.Big
浏览 16提问于2022-10-31得票数 0
回答已采纳
我正在尝试从PySpark查询BigQuery中的__TABLES__数据。我使用下面的代码来查询系统表： from pyspark.sql import SparkSession
spark = SparkSession.builder\
.config('parentProject', 'my-parent-project')\
.config('spark.jars.packages', 'com.google.cloud.spark:spark-bigquery-with-dependencies_2.12:
浏览 27提问于2021-06-28得票数 0
当我在我的电脑上尝试来自的Michael的bigquery代码片段时，我遇到了"401未授权“的问题。根据ryguyrg的建议，我同步了我的计算机时间(通过单击“立即更新”)，代码工作了。但问题是，过了一段时间，可能是几分钟后，当我重新运行代码时，它再次失败，出现401错误。因此，几乎每次我想运行一个大的查询请求时，我都必须手动同步我的计算机时间。
我非常确定我的计算机工作得很好，相对于服务器的时间差不应该超过几毫秒。那么到底是什么导致了这个问题呢？我是否应该尝试在请求之前同步代码中的时间，还是有更好的方法？
以下是401错误信息，以供参考：
Exception in thread &
浏览 0提问于2012-05-12得票数 3
回答已采纳
我通过Java访问bigquery，以便检查表是否已经存在于数据集中。在上周五(11/7)之后，我的java代码有时会返回null，并抛出nullPointerException。例如,
Bigquery bigquery = new Bigquery.Builder(HTTP_TRANSPORT, JSON_FACTORY, credential)
.setApplicationName("BigQuery-Service-Accounts/0.1")
.setHttpRequestInitializer(credential)
浏览 0提问于2014-11-12得票数 0
我在servlet中打包了一个数据流作业(在BlockingDataflowPipelineRunner模式下运行，每天由CRON作业(在AppEngine中)触发)。
当管道完成时，我无法执行一些Java脚本。它在使用Jetty在本地启动时工作，但在使用AppEngine部署时不起作用。
做这样一件事最好的方法是什么？
编辑:这是我得到的错误。基本上，我尝试先将数据沉入云存储中，然后执行BigQuery修补程序，然后加载标准的java代码。
在日志记录中，这是在Dataflow日志之后可以找到的内容(虽然我看不到任何“停止数据流工作人员”日志，这很奇怪.)：
javax.net.ssl.S
浏览 7提问于2017-08-03得票数 0
回答已采纳
我在Google Dataflow中运行了一个Apache beam流水线。它从Kafka中读取数据并将其流式插入到Bigquery。
但在bigquery流插入步骤中，它抛出了大量警告-
java.lang.RuntimeException: ManagedChannel allocation site
at io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init> (ManagedChannelOrphanWrapper.java:93)
at io.grpc.internal
浏览 7提问于2021-06-01得票数 5
当我试图从桌面上的Java应用程序通过Java API访问大型查询时，我遇到了一个问题。代码为：
import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
import com.google.api.client.http.HttpTransport;
import com.google.api.client.http.javanet.NetHttpTransport;
import com.google.api.client.json.JsonFactory;
import com.google.api.cli
浏览 19提问于2016-08-29得票数 2
回答已采纳
嗨，我尝试在Dataproc中使用java client library从BigQuery中删除一个表，启动了spark-shell，如下所示： spark-shell --packages com.google.cloud:google-cloud-bigquery:1.59.0 并导入以下依赖项 import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.FieldValueList;
import
浏览 18提问于2019-01-21得票数 2
回答已采纳
2回答
我试着跑到下面-
select prd_cat, product_category from
(
select split( product_category,".") as prd_cat,product_category from
test_dataset.cosme_raw_table
where product_link = "XXX"
) as a
group by prd_cat,product_category;
当我使用BigQuery网络接口运行它时
浏览 0提问于2018-10-18得票数 1
回答已采纳
1回答
我正在尝试使用Bigquery页面中提供的完整源代码从java运行Google查询：
代码已更改为适合我的项目，所有客户端库都已安装完毕，运行后我一直收到以下错误消息：
线程"main“中的异常: com.google.api.client.googleapis.services.json.AbstractGoogleJsonClient.(Lcom/google/api/client/http/HttpTransport;Lcom/google/api/client/json/JsonFactory;Ljava/lang/String;Ljava/lang/String;Lcom
浏览 5提问于2014-07-02得票数 2
是否有一种方法将侧输入应用于Apache中的BigQueryIO.read()操作。
例如，我在PCollection中有一个值，我想在查询中使用这个值从BigQuery表中获取数据。这有可能使用侧输入吗？还是应该在这种情况下使用其他的东西呢？
我在类似的情况下使用了NestedValueProvider，但我想只有当某个值依赖于我的运行时值时，我们才能使用它。或者我能用同样的东西吗？如果我错了，请纠正我。
我试过的密码：
Bigquery bigQueryClient = start_pipeline.newBigQueryClient(options.as(BigQueryOptions.
浏览 1提问于2017-07-31得票数 4
回答已采纳
我是Google Cloud & BigQuery的新手。我回顾了其他十几个似乎相关的问题，没有看到我在这些答案中遗漏了什么。我想查询一个公共数据集。
错误：
Caused by: com.google.api.client.googleapis.json.GoogleJsonResponseException: 403 Forbidden
{
"code" : 403,
"errors" : [ {
"domain" : "global",
"message" : "Acc
浏览 0提问于2019-03-27得票数 1
回答已采纳
我们正在使用Bigquery API https://github.com/googleapis/java-bigquery，我正在尝试使用以下代码片段执行更新操作： String dmlQuery = String.format("update dataset.Student set Stud_Name = \"Shruti11\", Stud_Class=\"II\" where Stud_Id = 300", datasetName, tableName);
QueryJobConfiguration dmlQ
浏览 25提问于2020-06-11得票数 0
1回答
我使用一个服务帐户使用java使用大查询存储API将数据写入大查询，我看到下面的错误。我是否需要向服务帐户提供任何其他角色？
错误: 00:44:38 \x{e76f}错误: com.google.api.gax.rpc.PermissionDeniedException: io.grpc.StatusRuntimeException: PERMISSION_DENIED: Request没有足够的身份验证范围。
服务帐户的当前角色: BigQuery管理、BigQuery数据所有者、BigQuery数据编辑器
代码片段：
Map<String, Object> m
浏览 19提问于2022-09-29得票数 1
1回答
我正在尝试执行ApacheBEAMSDK2.4和库com.google.cloud.bigquery，但是例外
Exception in thread main java.lang.NoSuchMethodError com.google.api.client.googleapis.services.json.AbstractGoogleJsonClient$Builder.setBatchPath(LjavalangString;)LcomgoogleapiclientgoogleapisservicesAbstractGoogleClient$Builder;
at com.google.
浏览 0提问于2018-06-28得票数 0
尝试使用中描述的“服务器到服务器授权”来授权访问谷歌BigQuery。我的certificate.p12和ServiceAccountId设置正确。但是我经常得到一个异常：
com.google.api.client.json.JsonFactory.createJsonGenerator(Ljava/io/OutputStream;Ljava/nio/charset/Charset;)Lcom/google/api/client/json/JsonGenerator;
java.lang.AbstractMethodError: com.google.api.client.json.Jso
浏览 0提问于2013-03-26得票数 1
4回答
我正在尝试使用方法访问谷歌BigQuery。我的代码如下：
private static final HttpTransport HTTP_TRANSPORT = new NetHttpTransport();
private static final JsonFactory JSON_FACTORY = new JacksonFactory();
GoogleCredential credentials = new GoogleCredential.Builder()
.setTransport(HTTP_TRANSPORT)
.setJs
浏览 0提问于2012-05-10得票数 3
1回答
我对com.google.api.services有一些问题。我正在使用此版本的"BigQuery API v2 (修订版459)"：
实际上，"getConnectionProperties()“方法并不存在.这是一个完全的错误：
线程"main“中的com.google.api.services.bigquery.model.JobConfigurationQuery.getConnectionProperties()Ljava/util/List；异常:com.google.api.services.bigquery.model.JobConfigura
浏览 5提问于2020-12-30得票数 0
回答已采纳
我正在使用大查询示例代码来处理大查询。在使用大型查询api读取数据集列表时，我得到了以下错误。
代码是
Bigquery bigquery = Bigquery.builder(httpTransport, jsonFactory)
.setHttpRequestInitializer(requestInitializer)
.setJsonHttpRequestInitializer(new JsonHttpRequestInitializer() {
public void initialize(JsonHttpRequest reque
浏览 0提问于2012-05-04得票数 0
回答已采纳
我正在尝试使用BigQuery存储API获取一个巨大的BigQuery表。目前，我使用一个流顺序获取数据。该程序将在使用数十个虚拟CPU的服务器上运行，因此我希望并行化表的获取以获得性能。我使用的bq存储版本是google.cloud.bigquery.storage.v1，我在中看到，为了并行计算多个流，可以指定一个分片策略为BALANCED，但它看起来在v1中并不存在。
此选项是否仍然存在？否则，我如何实现并行会话呢？
from google.cloud.bigquery_storage import types
from google.cloud import bigquery_stor
浏览 0提问于2021-06-15得票数 0
当我们试图通过在App Engine环境中执行的HEAD请求检查BigQuery中是否存在数据集时，我们遇到了奇怪的错误。请看下面的代码。
bigquery.datasets().get(projectNumber, datasetId).executeUsingHead();
如果代码在本地开发服务器上运行，则可以成功工作，但是，当部署在谷歌基础设施上时，我们会得到IOException。
...
Caused by: java.io.IOException:
at com.google.appengine.api.urlfetch.URLFetchServiceImpl.convertA
浏览 1提问于2013-08-04得票数 0
我想上传一个java cron作业，以便进行一些查询，并将表从BigQuery导出到Google，每周一次。为此，我使用将cron上传到AppEngine。
问题是，我的java cron作业调用了一个具有google依赖项的java类来访问BigQuery，但是当cron被上传到AppEngine时，会出现以下错误：
Error for /cron/gaejcronjob
java.lang.NoClassDefFoundError: com/google/api/client/json/JsonFactory
我读过这个问题：，但是它的反应不能解决这个问题。
编辑：(添加了pom.xml
浏览 7提问于2015-12-23得票数 0
回答已采纳
1回答
我有以下代码：
private BigQuery bigQuery() throws IOException
{
File credentialsPath = new File(path);
GoogleCredentials credentials;
try (FileInputStream serviceAccountStream = new FileInputStream(credentialsPath)) {
credentials = ServiceAccoun
浏览 13提问于2022-04-28得票数 0
我是谷歌bigquery的新手，我刚刚尝试运行谷歌BigQueryJavaGettingStarted，但我遇到了一些问题。它给我的错误消息是：“setDataStoreFactory(FileDataStoreFactory)方法未定义GoogleAuthorizationCodeFlow.Builder类型”，“GoogleClientSecrets类型中的方法load(JsonFactory，InputStream)不适用于参数(JacksonFactory，Reader)”。我不明白为什么它会给我这样的错误，因为我已经从教程中导入了所有特定的jar文件到我的项目中。因此，任何关于如何修
浏览 0提问于2014-09-24得票数 1
我正在尝试使用pandas和pyspark从BigQuery中读取数据。我能够获得数据，但不知何故得到以下错误，同时转换为火花DataFrame。
py4j.protocol.Py4JJavaError: An error occurred while calling o28.showString.
: java.lang.IllegalStateException: Could not find TLS ALPN provider; no working netty-tcnative, Conscrypt, or Jetty NPN/ALPN available
at com.goo
浏览 61提问于2019-07-11得票数 0
我是Bigquery的新开发人员。我正在使用Java代码和从导入的库在中学习教程。但是，我无法将库加载到import com.google.api.services.bigquery.model.DatasetList; import com.google.api.services.bigquery.model.GetQueryResultsResponse; import com.google.api.services.bigquery.model.Job等Java代码中。请告诉我如何解决这种情况。
谢谢
浏览 2提问于2014-06-16得票数 1
我试着用下面的方法读取GBQ表，
from pyspark.sql.functions import col, current_timestamp
def analyze(spark, config, query = None):
df = spark.read \
.format("bigquery") \
.load("projectName.dataset.tablename")
resultDf = df \
.filter(col('colName')=='
浏览 7提问于2022-06-07得票数 3
我正在用getQueryResults从bigquery作业中检索一个列表，(在我看来)，向JSON的转换似乎失败了。我已经找到了，并尝试了如下注释：
@JsonAutoDetect(fieldVisibility = Visibility.ANY)
虽然没有成功。
这里是代码的一个片段：
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.google.a
浏览 2提问于2016-10-08得票数 0
回答已采纳
日安，
我最近通过java api为bigquery测试了Oauth2.0安装的应用程序身份验证。我使用作为源代码，因为我想让用户更容易访问(让他们复制代码太难看了)
如果我在GoogleAuthorizationCodeflow中使用SetAccessType(离线)，它会提示我自动刷新访问令牌。
在相关问题中，我想问一下，如果我使用具有刷新令牌的凭据来授权具有com.google.api.services.bigquery.Bigquery.Builder.Builder(HttpTransport传输、jsonFactory JsonFactory、HttpRequestInitiali
浏览 0提问于2012-08-25得票数 1
我正在尝试从BigQuery连接器捕获一个预期的异常。异常的类是：com.google.api.client.googleapis.json.GoogleJsonResponseException和我在CloudStorage连接器抛出这个异常之前就已经成功地捕获了它。
当我在Dataproc (Spark)中运行代码时，抛出的异常类似于此异常的阴影版本：com.google.cloud.hadoop.repackaged.bigquery.com.google.api.client.googleapis.json.GoogleJsonResponseException。
我的代码如下所示：
浏览 0提问于2019-08-08得票数 2
回答已采纳
我正在尝试从google BigQuery接收一些数据，并在我的eclipse控制台上显示结果，以便开始使用BigQuery和Java。基本上，我遵循了谷歌提供的说明，我在这里找到了：
因此，我的示例Java代码看起来像来自google的快速入门示例：
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.Dataset;
import com.google.cloud.bigquery.Datas
浏览 2提问于2017-08-23得票数 1
1回答
在NaN表中，我们可以使用isNaN()检查biqquery的值。 但是如何用java (jvm语言)将NaN写到bigquery表中呢？ 是否写入字符串"NaN"？ 欢迎任何评论。谢谢 **更新** 我们尝试发送Double.NaN，但大型查询不接受它并抛出异常。不知道为什么。 Error sending insert request, table: xxxx
com.google.cloud.bigquery.BigQueryException: java.lang.IllegalArgumentException
at com.google.cloud.bigquery
浏览 10提问于2020-09-04得票数 0
找到了我问题的答案:对于那些有同样问题的人。
回答:在使用HTTP时，我需要将jars放在within /lib目录中。否则，我可以将它们保存在java构建路径(库)下。因此，在eclispe中，右键单击lib，然后添加Google并选择BigQuery.。
我正在用大查询测试google应用引擎。
当我将它作为一个应用程序运行时，我能够在eclipse中运行大查询，但是当我作为一个HttpServlet运行它时，我总是得到以下错误！
java.lang.NoClassDefFoundError: com/google/api/client/json/JsonFactory
下面是我使用的确切
浏览 3提问于2016-05-09得票数 0
回答已采纳
2回答
弹簧和螺纹安全
、、
我当时正在研究java.util.concurrent包，我想到了一个问题:当我使用Spring时，我应该担心多线程场景吗？
例如，我有一个基于Spring的API。我的rest服务之一更新了ArrayList。然而，ArrayList并不是线程安全的，这可能导致数据不一致。但是，我使用的是Spring框架。
问题是：，我是否必须将当前的ArrayList更改为java或Spring框架本身的并发集合之一，这是线程安全的，我不应该担心多线程方案？
浏览 2提问于2016-10-03得票数 3
回答已采纳
我的团队开发的Dataflow管道突然开始卡住，停止处理我们的事件。他们的工作日志里充斥着警告信息，说有一个具体的步骤被卡住了。奇怪的是，失败的步骤是不同的，一个是BigQuery输出，另一个是云存储输出。
以下是我们正在接收的日志消息：
对于BigQuery输出：
Processing stuck in step <STEP_NAME>/StreamingInserts/StreamingWriteTables/StreamingWrite for at least <TIME> without outputting or completing in state fi
浏览 0提问于2019-03-04得票数 12
1回答
我想通过使用用户可编辑的Groovy来扩展具有脚本功能的Java应用程序。
我的问题是，Java脚本API文档对于API的使用模式有点简洁。
因此，我的用例是:有许多Groovy脚本(没有编码结构或对象，只是过程代码逐行运行)需要在多线程环境中完全分离和隔离运行，它们被赋予一些对象来处理绑定(因此应该可以在不同的输入参数上并行运行相同的脚本，并且我保证输入参数不是相同的对象实例)。此外，我还想创建一些可以在每个脚本中使用的通用功能。
我的问题是：
对于每一次执行，我是否需要一个新的ScriptEngine实例(通过ScriptEngineManager获得)，还是一个ScriptEngin
浏览 1提问于2011-06-01得票数 1
我们使用以下库：
<dependency>
<groupId>com.google.apis</groupId>
<artifactId>google-api-services-bigquery</artifactId>
<version>v2-rev114-1.17.0-rc</version>
</dependency>
<dependency>
<groupId>com.google.apis
浏览 2提问于2013-09-15得票数 0
回答已采纳
我的工作是创建数据管道，它从各种常规数据库和CSV文件中提取数据，.It将使用pyspark进行预处理，然后将结果数据写入BigQuery表。
我已经将jar文件gs://spark-lib/bigquery/spark-bigquery-with-dependencies_2.12-0.23.1.jar复制到$SPARK_HOME/jars文件夹中，并且在创建spark对象时已经在spark.jars.packages中指定了相同的内容。
请给出一些建议，因为我能找到的所有博客都是以DataProc为例。
spark = SparkSession. \
builder. \
浏览 7提问于2021-12-15得票数 1
回答已采纳
我的波束管道中有一个BigQueryIO.Write阶段，它是通过调用.withJsonSchema(String)来构造的。
inputStream.apply(
"save-to-bigquery",
BigQueryIO.<Event>write()
.withJsonSchema(jsonSchema)
.to((ValueInSingleWindow<Event> input) ->
new TableDestination(
浏览 7提问于2017-10-19得票数 5
回答已采纳
当我在本地运行Spark Scala代码时，我得到了以下错误： Exception in thread "main" com.google.cloud.spark.bigquery.repackaged.com.google.api.gax.rpc.InternalException: com.google.cloud.spark.bigquery.repackaged.io.grpc.StatusRuntimeException: INTERNAL: request failed: internal error
at com.google.cloud.spark.b
浏览 16提问于2020-04-08得票数 1
回答已采纳
1回答
我试图在大查询的表中插入数据，我跟踪了几个文档，最后的代码如下
HttpTransport TRANSPORT = new NetHttpTransport();
JsonFactory JSON_FACTORY = new JacksonFactory();
List<String> SCOPES = Arrays
.asList(BigqueryScopes.BIGQUERY);
GoogleCredential credential = null;
AssetManager am = this.getAssets
浏览 3提问于2016-11-08得票数 3
回答已采纳
2回答
我没有找到如何从指定的数据集中获取表。从Dataset US到dataset location EU，我希望使用dataset US迁移表。我希望在dataset US的paralel过程中获取所有表，并在dataset EU中编写这些表。
Beam 2.4使用的是com.google.api.services.bigquery v2-rev374-1.22.0.这也是您应该在第2.4束中使用的库。
代码在DirectRunner中成功运行，但如果我使用DataflowRunner运行，则不会运行并引发错误
un 29, 2018 1:52:48 PM com.google.api.clien
浏览 0提问于2018-06-29得票数 1
1回答
我正在使用GoogleApp引擎，偶尔当我通过JSON API向BigQuery发送查询时，我会得到不正确的结果。它通常仅限于BigQuery中的单个表(我为创建的每个批处理作业创建一个新表)。当我在生产中遇到这个问题时，我会记录我提交的查询，并尝试通过BigQuery仪表板运行它，该仪表板的运行时间比预期的要长，但会返回预期的结果。
响应中没有任何指示问题的内容。jobComplete返回为True，但我没有看到rows，只有jobReference、schema和totalRows = 0。
在这种情况下，即使我希望当前调用返回结果，进行调用以获取作业结果是否合适？
相关代码：
http
浏览 0提问于2012-12-07得票数 2
回答已采纳
我有问题连接到谷歌的BigQuery，而遵循这个在Java。
我的问题是我不能解析这个方法：
GoogleCredentials.getApplicationDefault(HttpTransport t, JsonFactory f);
即使我导入的是正确的包：
import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
我添加了我认为正确的库：
com.google.oauth-client:google-oauth-client:1.19.0
下面是我的完整代码：
package com.test.teste
浏览 1提问于2015-07-24得票数 0
1回答
我是数据流的新手，并且尝试在大查询中动态获取表的模式。此外，我还需要在BigQueryIO.write.to()中使用动态目标类来动态获取目标表的名称。如果在执行管道之前为目标表提供了模式，那么它就会起作用。但是为了动态地获取模式，我使用了BigQuery片段，它接受datasetId和tableId作为输入，并返回给定表的模式。当尝试运行带有代码段的管道时，它会给出下面提到的错误。
任何帮助都是非常感谢的。提前谢谢。
Exception in thread "main" java.lang.NoSuchMethodError: com.google.api.client.go
浏览 2提问于2018-07-06得票数 0
我是爪哇的初学者。你能告诉我为什么下面的代码检测到一个错误吗，尽管我在下面的谷歌网址中使用了完全相同的代码作为例子：
单词bigquery是红色的，错误是: bigquery不能被解析。
我记得我想通过使用tabledata().insertAll()方法将我的数据一次一条地传输到BigQuery中。
这是我的代码：
import java.io.IOException;
import java.util.*;
import com.google.api.services.bigquery.*;
import com.google.api.services.bigquery.model.*;
浏览 0提问于2014-04-25得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
