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 <[email protected]> Authored: Sun Apr 9 22:47:03 2017 +0300 Committer: Aviem Zur <[email protected]> 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(-) ----------------------------------------------------------------------
