This closes #2073
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fe1d4124 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fe1d4124 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fe1d4124 Branch: refs/heads/master Commit: fe1d4124e7d51ec45869fb9e95cc8243f5891553 Parents: ea33e33 38e00f3 Author: Stas Levin <stasle...@apache.org> Authored: Sun Apr 2 13:07:28 2017 +0300 Committer: Stas Levin <stasle...@apache.org> Committed: Sun Apr 2 13:07:28 2017 +0300 ---------------------------------------------------------------------- .../runners/spark/io/SparkUnboundedSource.java | 36 ++++++++++++++++++-- .../spark/stateful/StateSpecFunctions.java | 21 +++++++++--- 2 files changed, 50 insertions(+), 7 deletions(-) ----------------------------------------------------------------------
