This closes #1706
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f03f6ac1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f03f6ac1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f03f6ac1 Branch: refs/heads/master Commit: f03f6ac192dcc5f1ba92d9639b153a3afba3340d Parents: 5fe7844 50daea2 Author: Stas Levin <stasle...@apache.org> Authored: Thu Feb 16 11:18:24 2017 +0200 Committer: Stas Levin <stasle...@apache.org> Committed: Thu Feb 16 11:18:24 2017 +0200 ---------------------------------------------------------------------- .../apache/beam/sdk/testing/Annotations.java | 72 +++ .../apache/beam/sdk/testing/TestPipeline.java | 66 ++- .../apache/beam/sdk/metrics/MetricsTest.java | 6 +- .../beam/sdk/testing/TestPipelineTest.java | 504 +++++++++++-------- .../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 9 +- 5 files changed, 417 insertions(+), 240 deletions(-) ----------------------------------------------------------------------
