This closes #2277
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4ffd43ed Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4ffd43ed Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4ffd43ed Branch: refs/heads/master Commit: 4ffd43ed7728c51f6af0b40970b741cc961e9636 Parents: 8d24098 695936f Author: Dan Halperin <dhalp...@google.com> Authored: Mon Mar 20 17:15:39 2017 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Mar 20 17:15:39 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/PubsubUnboundedSink.java | 24 ++++++++------------ .../beam/sdk/io/PubsubUnboundedSource.java | 8 +++---- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 13 ++++------- 3 files changed, 19 insertions(+), 26 deletions(-) ----------------------------------------------------------------------
