Fix: accept default stream name

README.md

@@ -50,20 +50,20 @@ If you are using Maven without the BOM, add this to your dependencies:
 If you are using Gradle 5.x or later, add this to your dependencies:
 
 ```Groovy
-implementation platform('com.google.cloud:libraries-bom:26.33.0')
+implementation platform('com.google.cloud:libraries-bom:26.34.0')
 
 implementation 'com.google.cloud:google-cloud-bigquerystorage'
 ```
 If you are using Gradle without BOM, add this to your dependencies:
 
 ```Groovy
-implementation 'com.google.cloud:google-cloud-bigquerystorage:3.3.0'
+implementation 'com.google.cloud:google-cloud-bigquerystorage:3.3.1'
 ```
 
 If you are using SBT, add this to your dependencies:
 
 ```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "3.3.0"
+libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "3.3.1"
 ```
 <!-- {x-version-update-end} -->
 
@@ -221,7 +221,7 @@ Java is a registered trademark of Oracle and/or its affiliates.
 [kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/java-bigquerystorage/java11.html
 [stability-image]: https://img.shields.io/badge/stability-stable-green
 [maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-bigquerystorage.svg
-[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-bigquerystorage/3.3.0
+[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-bigquerystorage/3.3.1
 [authentication]: https://github.com/googleapis/google-cloud-java#authentication
 [auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes
 [predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/Exceptions.java

@@ -150,6 +150,9 @@ private static StorageError toStorageError(com.google.rpc.Status rpcStatus) {
   @Nullable
   public static StorageException toStorageException(
       com.google.rpc.Status rpcStatus, Throwable exception) {
+    if (rpcStatus == null) {
+      return null;
+    }
     StorageError error = toStorageError(rpcStatus);
     Status grpcStatus =
         Status.fromCodeValue(rpcStatus.getCode()).withDescription(rpcStatus.getMessage());

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/SchemaAwareStreamWriter.java

@@ -467,6 +467,8 @@ private Builder(
 
         if (!tableMatcher.matches() && !defaultStreamMatcher.matches()) {
           throw new IllegalArgumentException("Invalid  name: " + streamOrTableName);
+        } else if (!tableMatcher.matches() && defaultStreamMatcher.matches()) {
+          this.streamName = streamOrTableName;
         } else {
           this.streamName = streamOrTableName + "/_default";
         }

google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriterTest.java

@@ -72,6 +72,7 @@ public class JsonStreamWriterTest {
   private static final String TEST_STREAM = "projects/p/datasets/d/tables/t/streams/_default";
   private static final String TEST_STREAM_2 = "projects/p/datasets/d2/tables/t2/streams/_default";
   private static final String TEST_TABLE = "projects/p/datasets/d/tables/t";
+  private static final String TEST_TABLE_DEFAULT = "projects/p/datasets/d/tables/t/_default";
   private static LocalChannelProvider channelProvider;
   private FakeScheduledExecutorService fakeExecutor;
   private FakeBigQueryWrite testBigQueryWrite;
@@ -198,6 +199,14 @@ public void testTwoParamNewBuilder()
     assertEquals(TEST_STREAM, writer.getStreamName());
   }
 
+  @Test
+  public void testConstructWriterUsingDefaultStreamName()
+      throws DescriptorValidationException, IOException, InterruptedException {
+    JsonStreamWriter writer =
+        getTestJsonStreamWriterBuilder(TEST_TABLE_DEFAULT, TABLE_SCHEMA).build();
+    assertEquals(TEST_TABLE_DEFAULT, writer.getStreamName());
+  }
+
   @Test
   public void testSingleAppendSimpleJson() throws Exception {
     FooType expectedProto = FooType.newBuilder().setFoo("allen").build();