You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/04/12 18:00:11 UTC
[1/2] beam git commit: [BEAM-115] Update timer/state fields on
ParDoPayload to use a map field for consistent tag usage
Repository: beam
Updated Branches:
refs/heads/master 571631a5e -> 435c3b426
[BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent tag usage
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b1148442
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b1148442
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b1148442
Branch: refs/heads/master
Commit: b1148442eefebd198a8a876ab29dbc6e9820bffa
Parents: 571631a
Author: Luke Cwik <lc...@google.com>
Authored: Wed Apr 12 09:25:39 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Apr 12 10:59:22 2017 -0700
----------------------------------------------------------------------
.../runner-api/src/main/proto/beam_runner_api.proto | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/b1148442/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
----------------------------------------------------------------------
diff --git a/sdks/common/runner-api/src/main/proto/beam_runner_api.proto b/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
index 3b7c5bd..ebbd928 100644
--- a/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
+++ b/sdks/common/runner-api/src/main/proto/beam_runner_api.proto
@@ -215,11 +215,11 @@ message ParDoPayload {
// the expected access pattern.
map<string, SideInput> side_inputs = 3;
- // (Optional) if the DoFn uses state, a list of the specs for cells.
- repeated StateSpec state_specs = 4;
+ // (Optional) A mapping of local state names to state specifications.
+ map<string, StateSpec> state_specs = 4;
- // (Optional) if the DoFn uses timers, a list of the specs for timers.
- repeated TimerSpec timer_specs = 5;
+ // (Optional) A mapping of local timer names to timer specifications.
+ map<string, TimerSpec> timer_specs = 5;
}
// Parameters that a UDF might require.
@@ -227,7 +227,7 @@ message ParDoPayload {
// The details of how a runner sends these parameters to the SDK harness
// are the subject of the Fn API.
//
-// The details ofo how an SDK harness delivers them to the UDF is entirely
+// The details of how an SDK harness delivers them to the UDF is entirely
// up to the SDK. (for some SDKs there may be parameters that are not
// represented here if the runner doesn't need to do anything)
//
[2/2] beam git commit: [BEAM-115] Update timer/state fields on
ParDoPayload to use a map field for consistent name usage
Posted by lc...@apache.org.
[BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent name usage
This closes #2511
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/435c3b42
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/435c3b42
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/435c3b42
Branch: refs/heads/master
Commit: 435c3b4267f527543849db3777f021fecc5964df
Parents: 571631a b114844
Author: Luke Cwik <lc...@google.com>
Authored: Wed Apr 12 10:59:58 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Apr 12 10:59:58 2017 -0700
----------------------------------------------------------------------
.../runner-api/src/main/proto/beam_runner_api.proto | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------