This closes #1666: Move ExecutionContext and related classes to runners-core
Move ExecutionContext and related classes to runners-core Update Dataflow worker to beam-master-20161221 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a9447a22 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a9447a22 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a9447a22 Branch: refs/heads/python-sdk Commit: a9447a2251f46496b7a773c8b07b3281dbc7a6fb Parents: 4843dc5 9d2b8e0 Author: Kenneth Knowles <k...@google.com> Authored: Wed Dec 21 10:24:11 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Wed Dec 21 10:24:11 2016 -0800 ---------------------------------------------------------------------- .../operators/ApexParDoOperator.java | 2 +- .../apex/translation/utils/NoOpStepContext.java | 3 +- .../beam/runners/core/AggregatorFactory.java | 1 - .../beam/runners/core/BaseExecutionContext.java | 176 +++++++++++++++++++ .../apache/beam/runners/core/DoFnRunners.java | 2 +- .../beam/runners/core/ExecutionContext.java | 102 +++++++++++ .../beam/runners/core/SimpleDoFnRunner.java | 2 +- .../beam/runners/core/SimpleOldDoFnRunner.java | 2 +- .../beam/runners/core/SimpleDoFnRunnerTest.java | 2 +- .../runners/core/SimpleOldDoFnRunnerTest.java | 3 +- .../runners/direct/AggregatorContainer.java | 2 +- .../runners/direct/DirectExecutionContext.java | 6 +- .../beam/runners/direct/EvaluationContext.java | 2 +- .../runners/direct/AggregatorContainerTest.java | 2 +- .../wrappers/streaming/DoFnOperator.java | 2 +- .../wrappers/streaming/WindowDoFnOperator.java | 2 +- .../beam/runners/dataflow/dataflow.properties | 4 +- .../spark/aggregators/SparkAggregators.java | 2 +- .../spark/translation/SparkProcessContext.java | 2 +- .../beam/sdk/util/BaseExecutionContext.java | 174 ------------------ .../apache/beam/sdk/util/ExecutionContext.java | 100 ----------- 21 files changed, 297 insertions(+), 296 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a9447a22/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java ----------------------------------------------------------------------