You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/26 17:47:50 UTC
[7/7] beam git commit: This closes #3233: [BEAM-115] Runner API
Translations for StateSpec and TimerSpec
This closes #3233: [BEAM-115] Runner API Translations for StateSpec and TimerSpec
Implement TimerSpec and StateSpec translation
Make Java serialized CombineFn URN public
Add case dispatch to StateSpec
Flesh out TimerSpec and StateSpec in Runner API
Allow translation to throw IOException
Mark CombineFnWithContext StateSpecs internal
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c687887d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c687887d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c687887d
Branch: refs/heads/master
Commit: c687887d2c1313f8c6c1a6d3b0b17a6808a5f134
Parents: 6bb204f 39220db
Author: Kenneth Knowles <kl...@google.com>
Authored: Fri May 26 10:36:50 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Fri May 26 10:36:50 2017 -0700
----------------------------------------------------------------------
.../core/construction/CombineTranslation.java | 4 +-
.../construction/PTransformTranslation.java | 3 +-
.../core/construction/ParDoTranslation.java | 215 ++++++++++++++++--
.../core/construction/ParDoTranslationTest.java | 218 ++++++++++++-------
.../src/main/proto/beam_runner_api.proto | 40 +++-
.../org/apache/beam/sdk/state/StateSpec.java | 53 +++++
.../org/apache/beam/sdk/state/StateSpecs.java | 53 ++++-
7 files changed, 478 insertions(+), 108 deletions(-)
----------------------------------------------------------------------