This closes #3203: Eliminate ExecutionContext and strip down StepContext to what we actually need
Remove unused pieces of DirectStepContext Revise StepContext javadoc Shorten excessive name in DirectExecutionContext Delete unused BaseStepContext Delete unused remnants in DirectExecutionContext Remove unused StepContext name methods Delete unused ExecutionContext Inline and delete BaseExecutionContext Remove writePCollectionViewData from the Beam codebase Implement StepContext directly in the DirectRunner Remove extraneous ExecutionContext parameter to BaseStepContext Move BaseStepContext to the top level Rename BaseExecutionContext.StepContext to BaseStepContext Remove StepContext.noteOutput Move StepContext to top level Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c84d3da3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c84d3da3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c84d3da3 Branch: refs/heads/master Commit: c84d3da386e2b5a8d12ac02d44c50c1e102508c4 Parents: 474345f b32a1c3 Author: Kenneth Knowles <[email protected]> Authored: Tue May 23 11:17:35 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue May 23 11:17:35 2017 -0700 ---------------------------------------------------------------------- .../apex/translation/utils/NoOpStepContext.java | 37 +---- .../beam/runners/core/BaseExecutionContext.java | 164 ------------------- .../apache/beam/runners/core/DoFnRunners.java | 1 - .../beam/runners/core/ExecutionContext.java | 99 ----------- .../beam/runners/core/SimpleDoFnRunner.java | 7 - .../apache/beam/runners/core/StepContext.java | 33 ++++ .../beam/runners/core/SimpleDoFnRunnerTest.java | 4 +- .../runners/core/StatefulDoFnRunnerTest.java | 4 +- .../runners/direct/DirectExecutionContext.java | 35 ++-- .../beam/runners/direct/EvaluationContext.java | 29 ++-- .../GroupAlsoByWindowEvaluatorFactory.java | 4 +- .../runners/direct/ParDoEvaluatorFactory.java | 2 +- ...littableProcessElementsEvaluatorFactory.java | 2 +- .../direct/StatefulParDoEvaluatorFactory.java | 2 +- .../runners/direct/EvaluationContextTest.java | 16 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 4 +- .../StatefulParDoEvaluatorFactoryTest.java | 4 +- .../functions/FlinkNoOpStepContext.java | 36 +--- .../wrappers/streaming/DoFnOperator.java | 34 +--- .../spark/translation/SparkProcessContext.java | 29 +--- .../beam/fn/harness/fake/FakeStepContext.java | 33 +--- 21 files changed, 97 insertions(+), 482 deletions(-) ----------------------------------------------------------------------
