com.google.cloud.bigquery.storage.util
com.google.cloud.bigquery.storage.v1
A client to BigQuery Storage API
The interfaces provided are listed below, along with usage samples.
BaseBigQueryReadClient
Service Description: BigQuery Read API.
The Read API can be used to read data from BigQuery.
Sample for BaseBigQueryReadClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try
(
BaseBigQueryReadClient
baseBigQueryReadClient
=
BaseBigQueryReadClient
.
create
())
{
ProjectName
parent
=
ProjectName
.
of
(
"[PROJECT]"
);
ReadSession
readSession
=
ReadSession
.
newBuilder
().
build
();
int
maxStreamCount
=
940837515
;
ReadSession
response
=
baseBigQueryReadClient
.
createReadSession
(
parent
,
readSession
,
maxStreamCount
);
}
BigQueryWriteClient
Service Description: BigQuery Write API.
The Write API can be used to write data to BigQuery.
For supplementary information about the Write API, see: https://cloud.google.com/bigquery/docs/write-api
Sample for BigQueryWriteClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try
(
BigQueryWriteClient
bigQueryWriteClient
=
BigQueryWriteClient
.
create
())
{
TableName
parent
=
TableName
.
of
(
"[PROJECT]"
,
"[DATASET]"
,
"[TABLE]"
);
WriteStream
writeStream
=
WriteStream
.
newBuilder
().
build
();
WriteStream
response
=
bigQueryWriteClient
.
createWriteStream
(
parent
,
writeStream
);
}
com.google.cloud.bigquery.storage.v1.stub
com.google.cloud.bigquery.storage.v1.stub.readrows
com.google.cloud.bigquery.storage.v1beta1
A client to BigQuery Storage API
The interfaces provided are listed below, along with usage samples.
BaseBigQueryStorageClient
Service Description: BigQuery storage API.
The BigQuery storage API can be used to read data stored in BigQuery.
The v1beta1 API is not yet officially deprecated, and will go through a full deprecation cycle ( https://cloud.google.com/products#product-launch-stages ) before the service is turned down. However, new code should use the v1 API going forward.
Sample for BaseBigQueryStorageClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try
(
BaseBigQueryStorageClient
baseBigQueryStorageClient
=
BaseBigQueryStorageClient
.
create
())
{
TableReferenceProto
.
TableReference
tableReference
=
TableReferenceProto
.
TableReference
.
newBuilder
().
build
();
ProjectName
parent
=
ProjectName
.
of
(
"[PROJECT]"
);
int
requestedStreams
=
1017221410
;
Storage
.
ReadSession
response
=
baseBigQueryStorageClient
.
createReadSession
(
tableReference
,
parent
,
requestedStreams
);
}
com.google.cloud.bigquery.storage.v1beta1.stub
com.google.cloud.bigquery.storage.v1beta1.stub.readrows
com.google.cloud.bigquery.storage.v1beta2
A client to BigQuery Storage API
The interfaces provided are listed below, along with usage samples.
BaseBigQueryReadClient
Service Description: BigQuery Read API.
The Read API can be used to read data from BigQuery.
New code should use the v1 Read API going forward, if they don't use Write API at the same time.
Sample for BaseBigQueryReadClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try
(
BaseBigQueryReadClient
baseBigQueryReadClient
=
BaseBigQueryReadClient
.
create
())
{
ProjectName
parent
=
ProjectName
.
of
(
"[PROJECT]"
);
ReadSession
readSession
=
ReadSession
.
newBuilder
().
build
();
int
maxStreamCount
=
940837515
;
ReadSession
response
=
baseBigQueryReadClient
.
createReadSession
(
parent
,
readSession
,
maxStreamCount
);
}
BigQueryWriteClient
Service Description: BigQuery Write API.
The Write API can be used to write data to BigQuery.
The google.cloud.bigquery.storage.v1 API should be used instead of the v1beta2 API for BigQueryWrite operations.
Sample for BigQueryWriteClient:
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try
(
BigQueryWriteClient
bigQueryWriteClient
=
BigQueryWriteClient
.
create
())
{
TableName
parent
=
TableName
.
of
(
"[PROJECT]"
,
"[DATASET]"
,
"[TABLE]"
);
WriteStream
writeStream
=
WriteStream
.
newBuilder
().
build
();
WriteStream
response
=
bigQueryWriteClient
.
createWriteStream
(
parent
,
writeStream
);
}
