From 322cdbffc3b4b6c428994fa5e1b805a446c55194 Mon Sep 17 00:00:00 2001 From: Owl Bot Date: Tue, 27 Feb 2024 19:34:54 +0000 Subject: [PATCH] =?UTF-8?q?=F0=9F=A6=89=20Updates=20from=20OwlBot=20post-p?= =?UTF-8?q?rocessor?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --- .../com/example/bigquerystorage/JsonWriterStreamCdc.java | 3 ++- .../java/com/example/bigquerystorage/WritePendingStream.java | 3 ++- .../com/example/bigquerystorage/WriteToDefaultStream.java | 5 +---- 3 files changed, 5 insertions(+), 6 deletions(-) diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/JsonWriterStreamCdc.java b/samples/snippets/src/main/java/com/example/bigquerystorage/JsonWriterStreamCdc.java index f7b2ed50c..0ba37ba13 100644 --- a/samples/snippets/src/main/java/com/example/bigquerystorage/JsonWriterStreamCdc.java +++ b/samples/snippets/src/main/java/com/example/bigquerystorage/JsonWriterStreamCdc.java @@ -174,7 +174,8 @@ public static void writeToDefaultStream( TableName parentTable = TableName.of(projectId, datasetName, tableName); try (JsonStreamWriter writer = JsonStreamWriter.newBuilder(parentTable.toString(), tableSchema) - .setRetrySettings(retrySettings).build()) { + .setRetrySettings(retrySettings) + .build()) { ApiFuture future = writer.append(data); // The append method is asynchronous. Rather than waiting for the method to complete, diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java index 42179f93f..e8de163ed 100644 --- a/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java +++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java @@ -155,7 +155,8 @@ void initialize(TableName parentTable, BigQueryWriteClient client) // https://googleapis.dev/java/google-cloud-bigquerystorage/latest/com/google/cloud/bigquery/storage/v1beta2/JsonStreamWriter.html streamWriter = JsonStreamWriter.newBuilder(writeStream.getName(), writeStream.getTableSchema()) - .setRetrySettings(retrySettings).build(); + .setRetrySettings(retrySettings) + .build(); } public void append(JSONArray data, long offset) diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java index 9307208bc..6c35f0601 100644 --- a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java +++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java @@ -35,12 +35,9 @@ import com.google.cloud.bigquery.storage.v1.Exceptions.StorageException; import com.google.cloud.bigquery.storage.v1.JsonStreamWriter; import com.google.cloud.bigquery.storage.v1.TableName; -import com.google.common.collect.ImmutableList; import com.google.common.util.concurrent.MoreExecutors; import com.google.protobuf.ByteString; import com.google.protobuf.Descriptors.DescriptorValidationException; -import io.grpc.Status; -import io.grpc.Status.Code; import java.io.IOException; import java.util.Map; import java.util.concurrent.Executors; @@ -63,7 +60,7 @@ public static void runWriteToDefaultStream() } private static ByteString buildByteString() { - byte[] bytes = new byte[]{1, 2, 3, 4, 5}; + byte[] bytes = new byte[] {1, 2, 3, 4, 5}; return ByteString.copyFrom(bytes); }