beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [3/3] beam git commit: This closes #2986
Date Tue, 09 May 2017 19:46:09 GMT
This closes #2986


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4e8c5f3d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4e8c5f3d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4e8c5f3d

Branch: refs/heads/master
Commit: 4e8c5f3deb61764c771f493ea1607d2e5de4f750
Parents: 9fc8198 fdd1089
Author: Eugene Kirpichov <kirpichov@google.com>
Authored: Tue May 9 12:42:44 2017 -0700
Committer: Eugene Kirpichov <kirpichov@google.com>
Committed: Tue May 9 12:42:44 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(-)
----------------------------------------------------------------------



Mime
View raw message