beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aviem...@apache.org
Subject [2/2] beam git commit: This closes #2033
Date Sun, 09 Apr 2017 19:47:36 GMT
This closes #2033


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

Branch: refs/heads/master
Commit: efd785f881d2c231f202c5031d6aeeb042177850
Parents: a0cfccd d958796
Author: Aviem Zur <aviemzur@gmail.com>
Authored: Sun Apr 9 22:47:03 2017 +0300
Committer: Aviem Zur <aviemzur@gmail.com>
Committed: Sun Apr 9 22:47:03 2017 +0300

----------------------------------------------------------------------
 .../beam/runners/spark/io/MicrobatchSource.java | 113 ++++++++++++++++---
 .../beam/runners/spark/io/SourceDStream.java    |  11 +-
 .../spark/stateful/StateSpecFunctions.java      |   6 +-
 .../ResumeFromCheckpointStreamingTest.java      |  14 ++-
 4 files changed, 118 insertions(+), 26 deletions(-)
----------------------------------------------------------------------



Mime
View raw message