beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] beam git commit: This closes #1048
Date Wed, 01 Feb 2017 22:29:58 GMT
This closes #1048


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

Branch: refs/heads/master
Commit: 0e6b3794c069bf30f7402492a3f61958873142cd
Parents: 420a718 e0c704f
Author: Dan Halperin <dhalperi@google.com>
Authored: Wed Feb 1 14:29:44 2017 -0800
Committer: Dan Halperin <dhalperi@google.com>
Committed: Wed Feb 1 14:29:44 2017 -0800

----------------------------------------------------------------------
 .../streaming/KafkaStreamingTest.java           |   4 +-
 .../ResumeFromCheckpointStreamingTest.java      |   2 +-
 sdks/java/io/kafka/pom.xml                      |   6 +
 .../org/apache/beam/sdk/io/kafka/KafkaIO.java   | 619 ++++++++-----------
 .../apache/beam/sdk/io/kafka/KafkaIOTest.java   |  17 +-
 5 files changed, 287 insertions(+), 361 deletions(-)
----------------------------------------------------------------------



Mime
View raw message