This closes #2149
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/806c53c1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/806c53c1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/806c53c1 Branch: refs/heads/master Commit: 806c53c18793b43e7ccd28f99662ee73a97237b4 Parents: cc12fd3 101715a Author: Thomas Groh <[email protected]> Authored: Tue Mar 14 15:54:42 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Tue Mar 14 15:54:42 2017 -0700 ---------------------------------------------------------------------- .../beam/examples/complete/AutoComplete.java | 2 +- .../examples/complete/StreamingWordExtract.java | 2 +- .../examples/complete/TrafficMaxLaneFlow.java | 2 +- .../beam/examples/complete/TrafficRoutes.java | 2 +- .../examples/cookbook/BigQueryTornadoes.java | 4 +- .../cookbook/CombinePerKeyExamples.java | 4 +- .../beam/examples/cookbook/FilterExamples.java | 4 +- .../beam/examples/cookbook/JoinExamples.java | 4 +- .../examples/cookbook/MaxPerKeyExamples.java | 4 +- .../beam/examples/cookbook/TriggerExample.java | 2 +- .../complete/game/utils/WriteToBigQuery.java | 2 +- .../game/utils/WriteWindowedToBigQuery.java | 2 +- .../org/apache/beam/sdk/io/package-info.java | 2 +- .../org/apache/beam/sdk/util/NameUtils.java | 5 + .../org/apache/beam/sdk/util/NameUtilsTest.java | 12 + .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 1707 ++++++++---------- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 288 ++- 17 files changed, 851 insertions(+), 1197 deletions(-) ----------------------------------------------------------------------
