You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/05/09 20:25:44 UTC
[2/2] beam git commit: This closes #3000: Cherry-pick #2986 into
release-2.0.0
This closes #3000: Cherry-pick #2986 into release-2.0.0
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/df2cdd89
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/df2cdd89
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/df2cdd89
Branch: refs/heads/release-2.0.0
Commit: df2cdd8990d28da5d86381d6833c94db405f3e65
Parents: 9f7521f 2ee22fa
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue May 9 13:22:35 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue May 9 13:22:35 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/io/kafka/KafkaIO.java | 321 +++++++------------
.../CoderBasedKafkaDeserializer.java | 70 ----
.../CoderBasedKafkaSerializer.java | 72 -----
.../apache/beam/sdk/io/kafka/KafkaIOTest.java | 112 +------
4 files changed, 119 insertions(+), 456 deletions(-)
----------------------------------------------------------------------