feat: add schema aware stream writer

Author: arturowczarek

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

@@ -216,7 +216,7 @@ public static StorageException toStorageException(Throwable exception) {
  }
 
  /**
- * This exception is thrown from {@link JsonStreamWriter#append()} when the client side Json to
+ * This exception is thrown from {@link SchemaAwareStreamWriter#append()} when the client side Json to
  * Proto serializtion fails. It can also be thrown by the server in case rows contains invalid
  * data. The exception contains a Map of indexes of faulty rows and the corresponding error
  * message.
@@ -348,15 +348,15 @@ protected InflightBytesLimitExceededException(String writerId, long currentLimit
  }
  }
  /**
- * Input Json data has unknown field to the schema of the JsonStreamWriter. User can either turn
- * on IgnoreUnknownFields option on the JsonStreamWriter, or if they don't want the error to be
- * ignored, they should recreate the JsonStreamWriter with the updated table schema.
+ * Input data object has unknown field to the schema of the CustomStreamWriter. User can either turn
+ * on IgnoreUnknownFields option on the CustomStreamWriter, or if they don't want the error to be
+ * ignored, they should recreate the CustomStreamWriter with the updated table schema.
  */
- public static final class JsonDataHasUnknownFieldException extends IllegalArgumentException {
+ public static final class DataHasUnknownFieldException extends IllegalArgumentException {
  private final String jsonFieldName;
 
- protected JsonDataHasUnknownFieldException(String jsonFieldName) {
- super(String.format("JSONObject has fields unknown to BigQuery: %s.", jsonFieldName));
+ public DataHasUnknownFieldException(String jsonFieldName) {
+ super(String.format("Source object has fields unknown to BigQuery: %s.", jsonFieldName));
  this.jsonFieldName = jsonFieldName;
  }