beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [16/16] beam git commit: This closes #3203: Eliminate ExecutionContext and strip down StepContext to what we actually need
Date Tue, 23 May 2017 18:18:15 GMT
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 <klk@google.com>
Authored: Tue May 23 11:17:35 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message