Abacn commented on code in PR #28272:
URL: https://github.com/apache/beam/pull/28272#discussion_r1319011517
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteTables.java:
##########
@@ -101,27 +99,28 @@ class WriteTables<DestinationT extends @NonNull Object>
@AutoValue
abstract static class Result {
abstract String getTableName();
-
+ // Downstream operations may rely on pane info which will get lost after a
ReShuffle
abstract Boolean isFirstPane();
+
+ abstract Long getPaneIndex();
Review Comment:
will revert the WriteTable.Result changes. Originally it was just to keep
WritePartition.Result and WriteTable.Result similar.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
