You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/03/20 16:21:31 UTC
[3/3] beam git commit: This closes #2238
This closes #2238
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6816d987
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6816d987
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6816d987
Branch: refs/heads/master
Commit: 6816d987013b8046f571b74763aad21637157896
Parents: d47ae87 b793fe0
Author: Thomas Groh <tg...@google.com>
Authored: Mon Mar 20 09:20:58 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Mar 20 09:20:58 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 | 10 +-
.../cookbook/CombinePerKeyExamples.java | 2 +-
.../beam/examples/cookbook/FilterExamples.java | 2 +-
.../examples/cookbook/MaxPerKeyExamples.java | 2 +-
.../beam/examples/cookbook/TriggerExample.java | 4 +-
.../complete/game/utils/WriteToBigQuery.java | 10 +-
.../game/utils/WriteWindowedToBigQuery.java | 6 +-
.../beam/runners/core/SplittableParDoTest.java | 2 +-
.../apache/beam/sdk/testing/GatherAllPanes.java | 1 +
.../org/apache/beam/sdk/testing/PAssert.java | 1 +
.../apache/beam/sdk/testing/PaneExtractors.java | 1 +
.../beam/sdk/testing/ValueInSingleWindow.java | 134 ------------
.../apache/beam/sdk/transforms/DoFnTester.java | 2 +-
.../beam/sdk/values/ValueInSingleWindow.java | 134 ++++++++++++
.../beam/sdk/testing/GatherAllPanesTest.java | 1 +
.../beam/sdk/testing/PaneExtractorsTest.java | 1 +
.../testing/ValueInSingleWindowCoderTest.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 215 ++++++++++++-------
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 117 +++++-----
23 files changed, 362 insertions(+), 292 deletions(-)
----------------------------------------------------------------------