This closes #2900
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3c1d411a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3c1d411a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3c1d411a Branch: refs/heads/master Commit: 3c1d411a259ead33301aa2a5fba8fb8a194e75e6 Parents: defb554 9d15249 Author: Eugene Kirpichov <[email protected]> Authored: Thu May 4 15:59:20 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Thu May 4 15:59:20 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 9 +----- .../pubsub/PubsubMessagePayloadOnlyCoder.java | 13 ++++---- .../PubsubMessageWithAttributesCoder.java | 14 ++++---- .../io/gcp/pubsub/PubsubUnboundedSource.java | 8 ++--- .../io/gcp/pubsub/PubsubUnboundedSinkTest.java | 34 +++++++++++++++++--- 5 files changed, 46 insertions(+), 32 deletions(-) ----------------------------------------------------------------------
