Skip to content

Commit

Permalink
Remove allowUnknownFields parameter
Browse files Browse the repository at this point in the history
  • Loading branch information
VeronicaWasson committed Dec 31, 2020
1 parent 91c67e0 commit ac98d25
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ public static void writeCommittedStream(String projectId, String datasetName, St
JSONArray jsonArr = new JSONArray();
jsonArr.put(record);

ApiFuture<AppendRowsResponse> future = writer.append(jsonArr, i, false);
ApiFuture<AppendRowsResponse> future = writer.append(jsonArr, i);
AppendRowsResponse response = future.get();
}

Expand Down Expand Up @@ -106,7 +106,7 @@ public static void writeToDefaultStream(String projectId, String datasetName, St
JSONArray jsonArr = new JSONArray();
jsonArr.put(record);

ApiFuture<AppendRowsResponse> future = writer.append(jsonArr, false);
ApiFuture<AppendRowsResponse> future = writer.append(jsonArr);
AppendRowsResponse response = future.get();
}
} catch (Exception e) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public static void writePendingStream(String projectId, String datasetName, Stri
JSONArray jsonArr = new JSONArray();
jsonArr.put(record);

ApiFuture<AppendRowsResponse> future = writer.append(jsonArr, false);
ApiFuture<AppendRowsResponse> future = writer.append(jsonArr);
AppendRowsResponse response = future.get();
}
FinalizeWriteStreamResponse finalizeResponse =
Expand Down

0 comments on commit ac98d25

Please sign in to comment.