You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2020/06/20 21:23:31 UTC
[beam] 01/01: Merge pull request #11990: [BEAM-9999] Remove Apex
runner
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 3384f6236b3d67daf96baa7833fca57ebf51220f
Merge: f3d5fc4 09b4d91
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Sat Jun 20 23:23:11 2020 +0200
Merge pull request #11990: [BEAM-9999] Remove Apex runner
.github/PULL_REQUEST_TEMPLATE.md | 10 +-
.github/autolabeler.yml | 1 -
.test-infra/jenkins/README.md | 1 -
...job_PostCommit_Java_ValidatesRunner_Apex.groovy | 44 --
README.md | 15 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 7 +-
examples/java/build.gradle | 4 -
examples/kotlin/build.gradle | 4 -
.../go/Introduction/Hello Beam/Hello Beam/task.md | 2 +-
.../Introduction/Hello Beam/Hello Beam/task.md | 2 +-
.../Introduction/Hello Beam/Hello Beam/task.md | 2 +-
ownership/JAVA_DEPENDENCY_OWNERS.yaml | 15 -
release/build.gradle | 1 -
.../src/main/groovy/MobileGamingCommands.groovy | 1 -
.../src/main/groovy/quickstart-java-apex.groovy | 45 --
release/src/main/scripts/mass_comment.py | 1 -
release/src/main/scripts/run_rc_validation.sh | 12 -
runners/apex/build.gradle | 118 ----
.../beam/runners/apex/ApexPipelineOptions.java | 67 ---
.../org/apache/beam/runners/apex/ApexRunner.java | 391 --------------
.../beam/runners/apex/ApexRunnerRegistrar.java | 54 --
.../apache/beam/runners/apex/ApexRunnerResult.java | 99 ----
.../apache/beam/runners/apex/ApexYarnLauncher.java | 415 --------------
.../apache/beam/runners/apex/TestApexRunner.java | 68 ---
.../org/apache/beam/runners/apex/package-info.java | 20 -
.../apex/translation/ApexPipelineTranslator.java | 188 -------
.../apex/translation/CreateValuesTranslator.java | 39 --
.../translation/FlattenPCollectionTranslator.java | 139 -----
.../apex/translation/GroupByKeyTranslator.java | 38 --
.../runners/apex/translation/ParDoTranslator.java | 265 ---------
.../apex/translation/ReadUnboundedTranslator.java | 39 --
.../apex/translation/TransformTranslator.java | 26 -
.../apex/translation/TranslationContext.java | 280 ----------
.../apex/translation/WindowAssignTranslator.java | 47 --
.../translation/operators/ApexFlattenOperator.java | 112 ----
.../operators/ApexGroupByKeyOperator.java | 234 --------
.../translation/operators/ApexParDoOperator.java | 601 ---------------------
.../operators/ApexProcessFnOperator.java | 183 -------
.../operators/ApexReadUnboundedInputOperator.java | 170 ------
.../translation/operators/ApexTimerInternals.java | 282 ----------
.../apex/translation/operators/package-info.java | 20 -
.../runners/apex/translation/package-info.java | 20 -
.../apex/translation/utils/ApexStateInternals.java | 437 ---------------
.../apex/translation/utils/ApexStreamTuple.java | 224 --------
.../translation/utils/CoderAdapterStreamCodec.java | 70 ---
.../apex/translation/utils/NoOpStepContext.java | 38 --
.../translation/utils/StateInternalsProxy.java | 69 ---
.../utils/ValueAndCoderKryoSerializable.java | 72 ---
.../apex/translation/utils/ValuesSource.java | 141 -----
.../apex/translation/utils/package-info.java | 20 -
.../beam/runners/apex/ApexRunnerRegistrarTest.java | 42 --
.../apache/beam/runners/apex/ApexRunnerTest.java | 101 ----
.../beam/runners/apex/ApexYarnLauncherTest.java | 135 -----
.../runners/apex/examples/UnboundedTextSource.java | 130 -----
.../beam/runners/apex/examples/WordCountTest.java | 186 -------
.../beam/runners/apex/examples/package-info.java | 20 -
.../translation/ApexGroupByKeyOperatorTest.java | 112 ----
.../FlattenPCollectionTranslatorTest.java | 104 ----
.../apex/translation/GroupByKeyTranslatorTest.java | 228 --------
.../apex/translation/ParDoTranslatorTest.java | 353 ------------
.../translation/ReadUnboundTranslatorTest.java | 118 ----
.../apex/translation/SideInputTranslationTest.java | 173 ------
.../operators/ApexTimerInternalsTest.java | 146 -----
.../translation/utils/ApexStateInternalsTest.java | 114 ----
.../apex/translation/utils/CollectionSource.java | 126 -----
.../test/resources/beam-runners-apex.properties | 20 -
runners/apex/src/test/resources/log4j.properties | 35 --
runners/apex/src/test/resources/words.txt | 3 -
.../beam/runners/jet/JetRunnerRegistrar.java | 2 +-
.../beam/runners/jet/JetTestRunnerRegistrar.java | 2 +-
sdks/java/javadoc/build.gradle | 1 -
.../src/main/resources/archetype-resources/pom.xml | 46 --
.../nexmark/src/main/resources/log4j.properties | 8 -
settings.gradle | 1 -
website/www/site/content/en/contribute/_index.md | 2 +-
.../en/contribute/ptransform-style-guide.md | 2 +-
.../site/content/en/contribute/release-guide.md | 8 +-
.../www/site/content/en/documentation/_index.md | 1 -
.../site/content/en/documentation/runners/apex.md | 77 ---
.../en/documentation/sdks/java/testing/nexmark.md | 61 ---
.../en/documentation/sdks/python-streaming.md | 4 -
.../site/content/en/get-started/beam-overview.md | 3 +-
.../site/content/en/get-started/quickstart-java.md | 27 +-
.../site/content/en/get-started/quickstart-py.md | 4 -
.../content/en/get-started/wordcount-example.md | 48 --
website/www/site/content/en/roadmap/apex-runner.md | 23 -
website/www/site/data/capability_matrix.yaml | 122 -----
website/www/site/data/works_with.yaml | 5 +-
.../layouts/partials/section-menu/en/roadmap.html | 1 -
.../layouts/partials/section-menu/en/runners.html | 1 -
90 files changed, 24 insertions(+), 7724 deletions(-)