This closes #2634
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7d6f8bde Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7d6f8bde Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7d6f8bde Branch: refs/heads/gearpump-runner Commit: 7d6f8bde707191e7354e08630f332a3a68c659f7 Parents: dc0fdcb eca553f Author: Eugene Kirpichov <[email protected]> Authored: Tue May 2 23:08:38 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Tue May 2 23:08:38 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 104 +++++----- .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 195 +++++++++++++------ .../pubsub/PubsubMessagePayloadOnlyCoder.java | 48 +++++ .../PubsubMessageWithAttributesCoder.java | 57 ++++++ .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 102 +++------- .../io/gcp/pubsub/PubsubUnboundedSource.java | 141 +++++--------- .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 32 +-- .../io/gcp/pubsub/PubsubUnboundedSinkTest.java | 50 +++-- .../gcp/pubsub/PubsubUnboundedSourceTest.java | 108 +++++----- 9 files changed, 482 insertions(+), 355 deletions(-) ----------------------------------------------------------------------
