beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [2/2] beam git commit: This closes #2044
Date Tue, 21 Feb 2017 17:33:47 GMT
This closes #2044


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

Branch: refs/heads/master
Commit: a991c9d85dc21023c2da92cdc89b4da974646e82
Parents: e43a290 ab850ac
Author: Davor Bonaci <davor@google.com>
Authored: Tue Feb 21 09:33:24 2017 -0800
Committer: Davor Bonaci <davor@google.com>
Committed: Tue Feb 21 09:33:24 2017 -0800

----------------------------------------------------------------------
 pom.xml                                         |  7 +++
 sdks/java/io/kafka/pom.xml                      |  5 ++
 .../apache/beam/sdk/io/kafka/ConsumerSpEL.java  | 60 ++++++++++++++++++++
 .../org/apache/beam/sdk/io/kafka/KafkaIO.java   | 20 ++++---
 4 files changed, 85 insertions(+), 7 deletions(-)
----------------------------------------------------------------------



Mime
View raw message