This closes #3842: [BEAM-2516] Key DirectRunner DoFn cache off step rather than DoFn
Key DoFnInstanceManager cache on AppliedPTransform Improve error message for bad DoFn URN in ParDoTranslation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3b04d135 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3b04d135 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3b04d135 Branch: refs/heads/master Commit: 3b04d1355954c7d5344ca80bbbce25cbee50a55a Parents: 8e391d9 2c018cd Author: Kenneth Knowles <[email protected]> Authored: Tue Sep 12 16:30:11 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue Sep 12 16:30:11 2017 -0700 ---------------------------------------------------------------------- .../core/construction/ParDoTranslation.java | 8 +++++- .../runners/direct/ParDoEvaluatorFactory.java | 30 +++++++++----------- ...littableProcessElementsEvaluatorFactory.java | 3 +- .../direct/StatefulParDoEvaluatorFactory.java | 15 ++++++++-- .../direct/TransformEvaluatorRegistry.java | 5 +++- 5 files changed, 40 insertions(+), 21 deletions(-) ----------------------------------------------------------------------
