[2/2] beam git commit: [BEAM-1177] This closes #1654

[jbonofre]

[BEAM-1177] This closes #1654


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

Branch: refs/heads/master
Commit: d1d85dfc76574e925dbefe9dfbf6edb8bcab8597
Parents: 5c61227 a49fbca
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Authored: Wed Jan 4 13:07:26 2017 +0100
Committer: Jean-Baptiste Onofré <jbono...@apache.org>
Committed: Wed Jan 4 13:07:26 2017 +0100

----------------------------------------------------------------------
 .../beam/runners/spark/io/MicrobatchSource.java |   4 +-
 .../runners/spark/io/SparkUnboundedSource.java  | 127 +++++++++++++------
 .../spark/stateful/StateSpecFunctions.java      |  37 ++++--
 3 files changed, 121 insertions(+), 47 deletions(-)
----------------------------------------------------------------------