This closes #1176
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/064f18a8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/064f18a8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/064f18a8 Branch: refs/heads/apex-runner Commit: 064f18a8f704ba4713701b7c8432a6f9b401a110 Parents: ee6ad2f 73db560 Author: Kenneth Knowles <k...@google.com> Authored: Thu Oct 27 10:48:35 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Oct 27 10:48:35 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 4 +- .../beam/runners/dataflow/util/DoFnInfo.java | 43 ++++++++++++++++++-- 2 files changed, 41 insertions(+), 6 deletions(-) ----------------------------------------------------------------------