Lokasi ngalangkungan proxy:   [ UP ]  
[Ngawartoskeun bug]   [Panyetelan cookie]                
Skip to content
This repository was archived by the owner on Feb 24, 2026. It is now read-only.

Commit b705783

Browse files
VeronicaWassonVeronicaWasson
authored
docs(samples): Update samples to v1 (#1364)
Co-authored-by: Veronica Wasson <3992422+MikeWasson@users.noreply.github.com>
1 parent c8f0051 commit b705783

6 files changed

Lines changed: 43 additions & 43 deletions

File tree

‎samples/snippets/src/main/java/com/example/bigquerystorage/BqToBqStorageSchemaConverter.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@
1919
import com.google.cloud.bigquery.Field;
2020
import com.google.cloud.bigquery.Schema;
2121
import com.google.cloud.bigquery.StandardSQLTypeName;
22-
import com.google.cloud.bigquery.storage.v1beta2.TableFieldSchema;
23-
import com.google.cloud.bigquery.storage.v1beta2.TableSchema;
22+
import com.google.cloud.bigquery.storage.v1.TableFieldSchema;
23+
import com.google.cloud.bigquery.storage.v1.TableSchema;
2424
import com.google.common.collect.ImmutableMap;
2525

2626
/** Converts structure from BigQuery client to BigQueryStorage client */

‎samples/snippets/src/main/java/com/example/bigquerystorage/ParallelWriteCommittedStream.java‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -20,17 +20,17 @@
2020
import com.google.api.core.ApiFuture;
2121
import com.google.api.core.ApiFutureCallback;
2222
import com.google.api.core.ApiFutures;
23-
import com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse;
24-
import com.google.cloud.bigquery.storage.v1beta2.BQTableSchemaToProtoDescriptor;
25-
import com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient;
26-
import com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest;
27-
import com.google.cloud.bigquery.storage.v1beta2.JsonToProtoMessage;
28-
import com.google.cloud.bigquery.storage.v1beta2.ProtoRows;
29-
import com.google.cloud.bigquery.storage.v1beta2.ProtoSchema;
30-
import com.google.cloud.bigquery.storage.v1beta2.ProtoSchemaConverter;
31-
import com.google.cloud.bigquery.storage.v1beta2.StreamWriterV2;
32-
import com.google.cloud.bigquery.storage.v1beta2.TableName;
33-
import com.google.cloud.bigquery.storage.v1beta2.WriteStream;
23+
import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
24+
import com.google.cloud.bigquery.storage.v1.BQTableSchemaToProtoDescriptor;
25+
import com.google.cloud.bigquery.storage.v1.BigQueryWriteClient;
26+
import com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest;
27+
import com.google.cloud.bigquery.storage.v1.JsonToProtoMessage;
28+
import com.google.cloud.bigquery.storage.v1.ProtoRows;
29+
import com.google.cloud.bigquery.storage.v1.ProtoSchema;
30+
import com.google.cloud.bigquery.storage.v1.ProtoSchemaConverter;
31+
import com.google.cloud.bigquery.storage.v1.StreamWriter;
32+
import com.google.cloud.bigquery.storage.v1.TableName;
33+
import com.google.cloud.bigquery.storage.v1.WriteStream;
3434
import com.google.common.util.concurrent.MoreExecutors;
3535
import com.google.protobuf.Descriptors.Descriptor;
3636
import com.google.protobuf.Descriptors.DescriptorValidationException;
@@ -161,8 +161,8 @@ private void writeToStream(
161161
BQTableSchemaToProtoDescriptor.convertBQTableSchemaToProtoDescriptor(
162162
writeStream.getTableSchema());
163163
ProtoSchema protoSchema = ProtoSchemaConverter.convert(descriptor);
164-
try (StreamWriterV2 writer =
165-
StreamWriterV2.newBuilder(writeStream.getName())
164+
try (StreamWriter writer =
165+
StreamWriter.newBuilder(writeStream.getName())
166166
.setWriterSchema(protoSchema)
167167
.setTraceId("SAMPLE:parallel_append")
168168
.build()) {

‎samples/snippets/src/main/java/com/example/bigquerystorage/WriteBufferedStream.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -18,14 +18,14 @@
1818

1919
// [START bigquerystorage_jsonstreamwriter_buffered]
2020
import com.google.api.core.ApiFuture;
21-
import com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse;
22-
import com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient;
23-
import com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest;
24-
import com.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest;
25-
import com.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse;
26-
import com.google.cloud.bigquery.storage.v1beta2.JsonStreamWriter;
27-
import com.google.cloud.bigquery.storage.v1beta2.TableName;
28-
import com.google.cloud.bigquery.storage.v1beta2.WriteStream;
21+
import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
22+
import com.google.cloud.bigquery.storage.v1.BigQueryWriteClient;
23+
import com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest;
24+
import com.google.cloud.bigquery.storage.v1.FlushRowsRequest;
25+
import com.google.cloud.bigquery.storage.v1.FlushRowsResponse;
26+
import com.google.cloud.bigquery.storage.v1.JsonStreamWriter;
27+
import com.google.cloud.bigquery.storage.v1.TableName;
28+
import com.google.cloud.bigquery.storage.v1.WriteStream;
2929
import com.google.protobuf.Descriptors.DescriptorValidationException;
3030
import com.google.protobuf.Int64Value;
3131
import java.io.IOException;

‎samples/snippets/src/main/java/com/example/bigquerystorage/WriteCommittedStream.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -18,12 +18,12 @@
1818

1919
// [START bigquerystorage_jsonstreamwriter_committed]
2020
import com.google.api.core.ApiFuture;
21-
import com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse;
22-
import com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient;
23-
import com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest;
24-
import com.google.cloud.bigquery.storage.v1beta2.JsonStreamWriter;
25-
import com.google.cloud.bigquery.storage.v1beta2.TableName;
26-
import com.google.cloud.bigquery.storage.v1beta2.WriteStream;
21+
import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
22+
import com.google.cloud.bigquery.storage.v1.BigQueryWriteClient;
23+
import com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest;
24+
import com.google.cloud.bigquery.storage.v1.JsonStreamWriter;
25+
import com.google.cloud.bigquery.storage.v1.TableName;
26+
import com.google.cloud.bigquery.storage.v1.WriteStream;
2727
import com.google.protobuf.Descriptors.DescriptorValidationException;
2828
import java.io.IOException;
2929
import java.util.concurrent.ExecutionException;

‎samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -18,16 +18,16 @@
1818

1919
// [START bigquerystorage_jsonstreamwriter_pending]
2020
import com.google.api.core.ApiFuture;
21-
import com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse;
22-
import com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest;
23-
import com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse;
24-
import com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient;
25-
import com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest;
26-
import com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse;
27-
import com.google.cloud.bigquery.storage.v1beta2.JsonStreamWriter;
28-
import com.google.cloud.bigquery.storage.v1beta2.StorageError;
29-
import com.google.cloud.bigquery.storage.v1beta2.TableName;
30-
import com.google.cloud.bigquery.storage.v1beta2.WriteStream;
21+
import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
22+
import com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest;
23+
import com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse;
24+
import com.google.cloud.bigquery.storage.v1.BigQueryWriteClient;
25+
import com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest;
26+
import com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse;
27+
import com.google.cloud.bigquery.storage.v1.JsonStreamWriter;
28+
import com.google.cloud.bigquery.storage.v1.StorageError;
29+
import com.google.cloud.bigquery.storage.v1.TableName;
30+
import com.google.cloud.bigquery.storage.v1.WriteStream;
3131
import com.google.protobuf.Descriptors.DescriptorValidationException;
3232
import java.io.IOException;
3333
import java.util.concurrent.ExecutionException;

‎samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@
2222
import com.google.cloud.bigquery.BigQueryOptions;
2323
import com.google.cloud.bigquery.Schema;
2424
import com.google.cloud.bigquery.Table;
25-
import com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse;
26-
import com.google.cloud.bigquery.storage.v1beta2.JsonStreamWriter;
27-
import com.google.cloud.bigquery.storage.v1beta2.TableName;
28-
import com.google.cloud.bigquery.storage.v1beta2.TableSchema;
25+
import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
26+
import com.google.cloud.bigquery.storage.v1.JsonStreamWriter;
27+
import com.google.cloud.bigquery.storage.v1.TableName;
28+
import com.google.cloud.bigquery.storage.v1.TableSchema;
2929
import com.google.protobuf.Descriptors.DescriptorValidationException;
3030
import java.io.IOException;
3131
import java.util.concurrent.ExecutionException;

0 commit comments

Comments
 (0)