beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [3/3] incubator-beam git commit: This closes #1579
Date Mon, 12 Dec 2016 19:38:36 GMT
This closes #1579


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

Branch: refs/heads/master
Commit: bfd21d72f334e49aee0839c2c6cd0099224a32a1
Parents: 321547f 74b0bef
Author: Kenneth Knowles <klk@google.com>
Authored: Mon Dec 12 11:37:46 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Mon Dec 12 11:37:46 2016 -0800

----------------------------------------------------------------------
 .../runners/spark/SparkPipelineOptions.java     |  5 +++
 .../beam/runners/spark/io/SourceDStream.java    | 21 +++++++++---
 .../runners/spark/io/SparkUnboundedSource.java  | 17 ++++++----
 .../streaming/KafkaStreamingTest.java           | 34 ++++++++++++--------
 .../ResumeFromCheckpointStreamingTest.java      | 17 ++++++----
 5 files changed, 63 insertions(+), 31 deletions(-)
----------------------------------------------------------------------



Mime
View raw message