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 <[email protected]> Authored: Wed Apr 12 09:25:39 2017 -0700 Committer: Luke Cwik <[email protected]> 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) //
