This closes #3216: [BEAM-2333] Runner API translation renames Rename Triggers to TriggerTranslation Rename WindowingStrategies to WindowingStrategyTranslation Rename Coders to CoderTranslation Rename ReadTranslator to ReadTranslation Rename WindowIntoTranslator to WindowIntoTranslation Rename ParDos to ParDoTranslation Rename PTransforms to PTransformTranslation Rename PCollections to PCollectionTranslation
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0637df1b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0637df1b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0637df1b Branch: refs/heads/master Commit: 0637df1bcc953855f0f003a72b95dd687b21fec9 Parents: 6418bcf 4fa38e2 Author: Kenneth Knowles <[email protected]> Authored: Wed May 24 13:13:46 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Wed May 24 13:13:46 2017 -0700 ---------------------------------------------------------------------- .../operators/ApexGroupByKeyOperator.java | 4 +- .../core/construction/CoderTranslation.java | 193 ++++++++++ .../beam/runners/core/construction/Coders.java | 193 ---------- .../construction/PCollectionTranslation.java | 98 ++++++ .../runners/core/construction/PCollections.java | 97 ------ .../construction/PTransformTranslation.java | 119 +++++++ .../runners/core/construction/PTransforms.java | 119 ------- .../core/construction/ParDoTranslation.java | 349 +++++++++++++++++++ .../beam/runners/core/construction/ParDos.java | 348 ------------------ .../core/construction/ReadTranslation.java | 127 +++++++ .../core/construction/ReadTranslator.java | 127 ------- .../core/construction/SdkComponents.java | 10 +- .../TransformPayloadTranslatorRegistrar.java | 2 +- .../core/construction/TriggerTranslation.java | 336 ++++++++++++++++++ .../runners/core/construction/Triggers.java | 336 ------------------ .../construction/WindowIntoTranslation.java | 61 ++++ .../core/construction/WindowIntoTranslator.java | 61 ---- .../core/construction/WindowingStrategies.java | 278 --------------- .../WindowingStrategyTranslation.java | 278 +++++++++++++++ .../core/construction/CoderTranslationTest.java | 165 +++++++++ .../runners/core/construction/CodersTest.java | 164 --------- .../PCollectionTranslationTest.java | 203 +++++++++++ .../core/construction/PCollectionsTest.java | 201 ----------- .../construction/PTransformTranslationTest.java | 189 ++++++++++ .../core/construction/PTransformsTest.java | 188 ---------- .../core/construction/ParDoTranslationTest.java | 234 +++++++++++++ .../runners/core/construction/ParDosTest.java | 233 ------------- .../core/construction/ReadTranslationTest.java | 179 ++++++++++ .../core/construction/ReadTranslatorTest.java | 179 ---------- .../construction/TriggerTranslationTest.java | 112 ++++++ .../runners/core/construction/TriggersTest.java | 111 ------ .../construction/WindowIntoTranslationTest.java | 127 +++++++ .../construction/WindowIntoTranslatorTest.java | 127 ------- .../construction/WindowingStrategiesTest.java | 110 ------ .../WindowingStrategyTranslationTest.java | 111 ++++++ .../GroupAlsoByWindowViaWindowSetNewDoFn.java | 4 +- .../beam/runners/core/ReduceFnTester.java | 10 +- .../GroupAlsoByWindowEvaluatorFactory.java | 4 +- .../dataflow/DataflowPipelineTranslator.java | 4 +- .../SparkGroupAlsoByWindowViaWindowSet.java | 4 +- ...SparkGroupAlsoByWindowViaOutputBufferFn.java | 4 +- 41 files changed, 2906 insertions(+), 2893 deletions(-) ----------------------------------------------------------------------
