beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject [2/2] beam git commit: [BEAM-1177] This closes #1654
Date Wed, 04 Jan 2017 12:33:49 GMT
[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é <jbonofre@apache.org>
Authored: Wed Jan 4 13:07:26 2017 +0100
Committer: Jean-Baptiste Onofré <jbonofre@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(-)
----------------------------------------------------------------------



Mime
View raw message