Skip to content

Commit 2258a2a

Browse files
committed
feat: add schema aware stream writer
1 parent 8eda934 commit 2258a2a

File tree

9 files changed

+815
-411
lines changed

9 files changed

+815
-411
lines changed

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -243,8 +243,8 @@ public String getStreamName() {
243243
}
244244

245245
/**
246-
* This exception is thrown from {@link JsonStreamWriter#append()} when the client side Json to
247-
* Proto serializtion fails. It can also be thrown by the server in case rows contains invalid
246+
* This exception is thrown from {@link SchemaAwareStreamWriter#append()} when the client side
247+
* Proto serialization fails. It can also be thrown by the server in case rows contains invalid
248248
* data. The exception contains a Map of indexes of faulty rows and the corresponding error
249249
* message.
250250
*/
@@ -363,15 +363,15 @@ protected InflightBytesLimitExceededException(String writerId, long currentLimit
363363
}
364364
}
365365
/**
366-
* Input Json data has unknown field to the schema of the JsonStreamWriter. User can either turn
367-
* on IgnoreUnknownFields option on the JsonStreamWriter, or if they don't want the error to be
368-
* ignored, they should recreate the JsonStreamWriter with the updated table schema.
366+
* Input data object has unknown field to the schema of the SchemaAwareStreamWriter. User can either turn
367+
* on IgnoreUnknownFields option on the SchemaAwareStreamWriter, or if they don't want the error to be
368+
* ignored, they should recreate the SchemaAwareStreamWriter with the updated table schema.
369369
*/
370-
public static final class JsonDataHasUnknownFieldException extends IllegalArgumentException {
370+
public static final class DataHasUnknownFieldException extends IllegalArgumentException {
371371
private final String jsonFieldName;
372372

373-
protected JsonDataHasUnknownFieldException(String jsonFieldName) {
374-
super(String.format("JSONObject has fields unknown to BigQuery: %s.", jsonFieldName));
373+
public DataHasUnknownFieldException(String jsonFieldName) {
374+
super(String.format("The source object has fields unknown to BigQuery: %s.", jsonFieldName));
375375
this.jsonFieldName = jsonFieldName;
376376
}
377377

0 commit comments

Comments
 (0)