This closes #2404
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/65ffd6c6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/65ffd6c6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/65ffd6c6 Branch: refs/heads/master Commit: 65ffd6c64bd1aed08dcb352962bab01b9bd9b3ca Parents: 50fc63a 475bf13 Author: Dan Halperin <[email protected]> Authored: Tue Apr 4 11:56:59 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue Apr 4 11:56:59 2017 -0700 ---------------------------------------------------------------------- .../complete/game/utils/WriteToBigQuery.java | 3 +- .../game/utils/WriteWindowedToBigQuery.java | 3 +- .../sdk/io/gcp/bigquery/BatchLoadBigQuery.java | 7 ++- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 5 +-- .../sdk/io/gcp/bigquery/StreamWithDeDup.java | 14 ++---- .../beam/sdk/io/gcp/bigquery/WriteResult.java | 47 ++++++++++++++++++++ 6 files changed, 59 insertions(+), 20 deletions(-) ----------------------------------------------------------------------
