This closes #2885
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ad12f631 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ad12f631 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ad12f631 Branch: refs/heads/master Commit: ad12f63162a4b03c61c815887dee24fb176065a9 Parents: 5b0a868 210e216 Author: Eugene Kirpichov <[email protected]> Authored: Wed May 3 19:19:00 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Wed May 3 19:19:00 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 22 +++---- .../sdk/io/gcp/pubsub/PubsubCoderRegistrar.java | 35 +++++++++++ .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 49 ++-------------- .../beam/sdk/io/gcp/pubsub/PubsubMessage.java | 61 ++++++++++++++++++++ .../pubsub/PubsubMessagePayloadOnlyCoder.java | 10 ++-- .../PubsubMessageWithAttributesCoder.java | 15 +++-- .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 12 ++-- .../io/gcp/pubsub/PubsubUnboundedSource.java | 16 ++--- .../io/gcp/pubsub/PubsubUnboundedSinkTest.java | 7 +-- .../gcp/pubsub/PubsubUnboundedSourceTest.java | 4 +- 10 files changed, 145 insertions(+), 86 deletions(-) ----------------------------------------------------------------------
