You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2026/04/30 05:03:15 UTC
(beam) branch nightly-refs/heads/master updated (281270cbee2 -> 083e57902b1)
This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 281270cbee2 Refactor StorageAPI BigQuery sink (#38264)
add febef3501f6 add auto gemini review comment workflow (#38309)
add d8d99c4b6ec Set gemini config.yaml to post code review on PR open (#38316)
add 7910b1b3793 Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries (#37377)
add 09febfd5d80 Revert "add auto gemini review comment workflow (#38309)" (#38318)
add 79f03db9e10 Remove mypy configuration (#38266)
add b05fbf4437a Remove Samza runner support (#38263)
add 0739dbbbbd3 Revert "Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries (#37377)" (#38321)
add 329488388fd Bump pytest from 8.4.2 to 9.0.3 in /sdks/python/container/ml/py312 (#38178)
add 70405656d36 Bump requests from 2.32.5 to 2.33.0 in /sdks/python/container/ml/py312 (#37968)
add a61ef0a7372 Bump requests (#37962)
add 28576032d43 Add outstanding parameters to processElement and onTimer signatures (#37933)
add ca5cbda4757 Bump torch from 2.7.1 to 2.8.0 in /sdks/python/container/ml/py312 (#38226)
add 63adaabeb19 Bump keras from 3.12.1 to 3.13.2 in /sdks/python/container/ml/py310 (#38198)
add 541d9bce15f Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py312 (#37781)
add 083e57902b1 update gemini review to not run on draft prs (#38333)
No new revisions were added by this update.
Summary of changes:
.gemini/config.yaml | 6 +-
.github/ISSUE_TEMPLATE/bug.yml | 2 +-
.github/ISSUE_TEMPLATE/failing_test.yml | 2 +-
.github/ISSUE_TEMPLATE/feature.yml | 2 +-
.github/ISSUE_TEMPLATE/task.yml | 2 +-
.github/autolabeler.yml | 1 -
.github/issue-rules.yml | 4 +-
...beam_PostCommit_Java_ValidatesRunner_Samza.json | 9 -
.github/workflows/README.md | 5 -
.github/workflows/beam_PostCommit_Go_VR_Samza.yml | 85 --
.../workflows/beam_PostCommit_Java_PVR_Samza.yml | 104 --
.../beam_PostCommit_Java_ValidatesRunner_Samza.yml | 100 --
...eam_PostCommit_Python_ValidatesRunner_Samza.yml | 110 --
.github/workflows/beam_PostCommit_XVR_Samza.yml | 107 --
.test-infra/BUILD_STATUS.md | 390 -------
.../src/main/resources/configuration.yaml | 2 +-
CHANGES.md | 1 +
build.gradle.kts | 3 -
.../apache/beam/runners/core/SimpleDoFnRunner.java | 51 +
runners/samza/build.gradle | 194 ----
runners/samza/job-server/build.gradle | 253 -----
.../beam/runners/samza/SamzaExecutionContext.java | 72 --
.../runners/samza/SamzaExecutionEnvironment.java | 44 -
.../apache/beam/runners/samza/SamzaJobInvoker.java | 82 --
.../beam/runners/samza/SamzaJobServerDriver.java | 101 --
.../samza/SamzaPipelineExceptionContext.java | 37 -
.../samza/SamzaPipelineLifeCycleListener.java | 44 -
.../beam/runners/samza/SamzaPipelineOptions.java | 182 ----
.../samza/SamzaPipelineOptionsValidator.java | 54 -
.../beam/runners/samza/SamzaPipelineResult.java | 161 ---
.../beam/runners/samza/SamzaPipelineRunner.java | 89 --
.../samza/SamzaPortablePipelineOptions.java | 32 -
.../runners/samza/SamzaPortablePipelineResult.java | 48 -
.../org/apache/beam/runners/samza/SamzaRunner.java | 213 ----
.../runners/samza/SamzaRunnerOverrideConfigs.java | 85 --
.../beam/runners/samza/SamzaRunnerRegistrar.java | 53 -
.../apache/beam/runners/samza/TestSamzaRunner.java | 109 --
.../runners/samza/adapter/BoundedSourceSystem.java | 449 --------
.../samza/adapter/UnboundedSourceSystem.java | 533 ---------
.../beam/runners/samza/adapter/package-info.java | 20 -
.../samza/container/BeamContainerRunner.java | 89 --
.../samza/container/BeamJobCoordinatorRunner.java | 78 --
.../samza/container/ContainerCfgLoader.java | 62 --
.../samza/container/ContainerCfgLoaderFactory.java | 30 -
.../beam/runners/samza/container/package-info.java | 20 -
.../samza/metrics/DoFnRunnerWithMetrics.java | 108 --
.../samza/metrics/FnWithMetricsWrapper.java | 50 -
.../runners/samza/metrics/SamzaGBKMetricOp.java | 194 ----
.../beam/runners/samza/metrics/SamzaMetricOp.java | 173 ---
.../samza/metrics/SamzaMetricOpFactory.java | 73 --
.../samza/metrics/SamzaMetricsContainer.java | 120 ---
.../metrics/SamzaTransformMetricRegistry.java | 208 ----
.../samza/metrics/SamzaTransformMetrics.java | 142 ---
.../beam/runners/samza/metrics/package-info.java | 20 -
.../apache/beam/runners/samza/package-info.java | 20 -
.../runners/samza/runtime/AsyncDoFnRunner.java | 188 ----
.../beam/runners/samza/runtime/BundleManager.java | 90 --
.../samza/runtime/ClassicBundleManager.java | 327 ------
.../apache/beam/runners/samza/runtime/DoFnOp.java | 579 ----------
.../runtime/DoFnRunnerWithKeyedInternals.java | 126 ---
.../runners/samza/runtime/FutureCollector.java | 67 --
.../runners/samza/runtime/FutureCollectorImpl.java | 99 --
.../beam/runners/samza/runtime/GroupByKeyOp.java | 243 -----
.../beam/runners/samza/runtime/KeyedInternals.java | 180 ----
.../beam/runners/samza/runtime/KeyedTimerData.java | 216 ----
.../runners/samza/runtime/KvToKeyedWorkItemOp.java | 37 -
.../org/apache/beam/runners/samza/runtime/Op.java | 64 --
.../beam/runners/samza/runtime/OpAdapter.java | 237 ----
.../beam/runners/samza/runtime/OpEmitter.java | 41 -
.../beam/runners/samza/runtime/OpMessage.java | 161 ---
.../samza/runtime/OutputManagerFactory.java | 31 -
.../samza/runtime/PortableBundleManager.java | 218 ----
.../beam/runners/samza/runtime/PortableDoFnOp.java | 467 --------
.../runners/samza/runtime/SamzaAssignContext.java | 56 -
.../samza/runtime/SamzaDoFnInvokerRegistrar.java | 35 -
.../runners/samza/runtime/SamzaDoFnRunners.java | 506 ---------
.../SamzaExecutableStageContextFactory.java | 61 --
.../runtime/SamzaMetricsBundleProgressHandler.java | 158 ---
.../samza/runtime/SamzaStateRequestHandlers.java | 179 ----
.../samza/runtime/SamzaStoreStateInternals.java | 1131 --------------------
.../samza/runtime/SamzaTimerInternalsFactory.java | 733 -------------
.../samza/runtime/SingletonKeyedWorkItem.java | 49 -
.../SplittableParDoProcessKeyedElementsOp.java | 248 -----
.../beam/runners/samza/runtime/WindowAssignOp.java | 53 -
.../beam/runners/samza/runtime/package-info.java | 20 -
.../beam/runners/samza/state/SamzaMapState.java | 40 -
.../beam/runners/samza/state/SamzaSetState.java | 39 -
.../beam/runners/samza/state/package-info.java | 20 -
.../samza/transforms/GroupWithoutRepartition.java | 60 --
.../samza/transforms/UpdatingCombineFn.java | 35 -
.../runners/samza/transforms/package-info.java | 20 -
.../runners/samza/translation/ConfigBuilder.java | 360 -------
.../runners/samza/translation/ConfigContext.java | 79 --
.../translation/FlattenPCollectionsTranslator.java | 111 --
.../samza/translation/GroupByKeyTranslator.java | 272 -----
.../samza/translation/ImpulseTranslator.java | 80 --
.../runners/samza/translation/PViewToIdMapper.java | 83 --
.../translation/ParDoBoundMultiTranslator.java | 563 ----------
.../translation/PortableTranslationContext.java | 117 --
.../runners/samza/translation/ReadTranslator.java | 91 --
.../translation/RedistributeByKeyTranslator.java | 64 --
.../samza/translation/ReshuffleTranslator.java | 134 ---
.../translation/SamzaImpulseSystemFactory.java | 146 ---
.../samza/translation/SamzaPipelineTranslator.java | 211 ----
.../SamzaPortablePipelineTranslator.java | 112 --
.../SamzaPortableTranslatorRegistrar.java | 25 -
.../samza/translation/SamzaPublishView.java | 66 --
.../SamzaPublishViewTransformOverride.java | 66 --
.../translation/SamzaPublishViewTranslator.java | 76 --
.../translation/SamzaTestStreamSystemFactory.java | 179 ----
.../translation/SamzaTestStreamTranslator.java | 148 ---
.../samza/translation/SamzaTransformOverrides.java | 62 --
.../translation/SamzaTranslatorRegistrar.java | 25 -
.../translation/SplittableParDoTranslators.java | 157 ---
.../runners/samza/translation/StateIdParser.java | 69 --
.../translation/TransformConfigGenerator.java | 40 -
.../samza/translation/TransformTranslator.java | 45 -
.../samza/translation/TranslationContext.java | 380 -------
.../samza/translation/WindowAssignTranslator.java | 80 --
.../runners/samza/translation/package-info.java | 20 -
.../beam/runners/samza/util/ConfigUtils.java | 43 -
.../apache/beam/runners/samza/util/DoFnUtils.java | 75 --
.../beam/runners/samza/util/FutureUtils.java | 67 --
.../beam/runners/samza/util/HashIdGenerator.java | 66 --
.../runners/samza/util/PipelineJsonRenderer.java | 335 ------
.../runners/samza/util/PortableConfigUtils.java | 43 -
.../beam/runners/samza/util/SamzaCoders.java | 77 --
.../samza/util/SamzaPipelineExceptionListener.java | 34 -
.../samza/util/SamzaPipelineTranslatorUtils.java | 61 --
.../apache/beam/runners/samza/util/StateUtils.java | 39 -
.../beam/runners/samza/util/StoreIdGenerator.java | 48 -
.../beam/runners/samza/util/WindowUtils.java | 74 --
.../beam/runners/samza/util/package-info.java | 20 -
runners/samza/src/main/resources/log4j.properties | 23 -
.../samza/src/main/resources/samza-conf.properties | 37 -
.../samza/SamzaPipelineOptionsValidatorTest.java | 60 --
.../samza/adapter/BoundedSourceSystemTest.java | 309 ------
.../runners/samza/adapter/TestBoundedSource.java | 188 ----
.../runners/samza/adapter/TestCheckpointMark.java | 40 -
.../runners/samza/adapter/TestSourceHelpers.java | 162 ---
.../runners/samza/adapter/TestUnboundedSource.java | 208 ----
.../samza/adapter/UnboundedSourceSystemTest.java | 405 -------
.../TestSamzaRunnerWithTransformMetrics.java | 323 ------
.../metrics/TestSamzaTransformMetricsRegistry.java | 191 ----
.../runners/samza/runtime/AsyncDoFnRunnerTest.java | 240 -----
.../samza/runtime/ClassicBundleManagerTest.java | 457 --------
.../samza/runtime/FutureCollectorImplTest.java | 92 --
.../runners/samza/runtime/GroupByKeyOpTest.java | 133 ---
.../runners/samza/runtime/KeyedTimerDataTest.java | 65 --
.../samza/runtime/PortableBundleManagerTest.java | 178 ---
.../SamzaMetricsBundleProgressHandlerTest.java | 187 ----
.../runtime/SamzaStoreStateInternalsTest.java | 432 --------
.../runtime/SamzaTimerInternalsFactoryTest.java | 752 -------------
.../samza/runtime/SdkHarnessDoFnRunnerTest.java | 48 -
.../samza/translation/ConfigGeneratorTest.java | 461 --------
.../samza/translation/SamzaImpulseSystemTest.java | 65 --
.../samza/translation/TranslationContextTest.java | 98 --
.../beam/runners/samza/util/DoFnUtilsTest.java | 84 --
.../beam/runners/samza/util/FutureUtilsTest.java | 112 --
.../samza/util/InMemoryMetricsReporter.java | 49 -
.../samza/util/PipelineJsonRendererTest.java | 146 ---
.../samza/util/PortableConfigUtilsTest.java | 58 -
.../runners/samza/util/TestHashIdGenerator.java | 85 --
.../beam/runners/samza/util/WindowUtilsTest.java | 87 --
runners/samza/src/test/resources/ExpectedDag.json | 373 -------
.../samza/src/test/resources/log4j-test.properties | 26 -
.../go/examples/large_wordcount/large_wordcount.go | 1 -
sdks/go/pkg/beam/runners/samza/samza.go | 35 -
sdks/go/pkg/beam/x/beamx/run.go | 1 -
sdks/go/test/build.gradle | 29 -
sdks/go/test/integration/expansions_test.go | 1 -
sdks/go/test/integration/integration.go | 49 -
.../integration/io/mongodbio/mongodbio_test.go | 1 -
.../integration/io/xlang/debezium/debezium_test.go | 1 -
.../go/test/integration/io/xlang/jdbc/jdbc_test.go | 1 -
.../test/integration/io/xlang/kafka/kafka_test.go | 1 -
.../test/integration/primitives/primitives_test.go | 1 -
.../test/integration/synthetic/synthetic_test.go | 2 +-
.../test/integration/wordcount/wordcount_test.go | 1 -
sdks/go/test/integration/xlang/xlang_test.go | 1 -
sdks/go/test/regression/lperror_test.go | 1 -
sdks/go/test/regression/pardo_test.go | 1 -
sdks/go/test/run_validatesrunner_tests.sh | 17 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 43 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 33 +
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 44 +
.../beam/sdk/transforms/reflect/DoFnSignature.java | 78 ++
.../sdk/transforms/reflect/DoFnSignatures.java | 19 +
.../construction/SplittableParDoNaiveBounded.java | 15 +
.../sdk/transforms/reflect/DoFnSignaturesTest.java | 76 ++
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 21 +
.../src/main/resources/archetype-resources/pom.xml | 11 -
.../src/main/resources/archetype-resources/pom.xml | 10 -
.../kfp/components/preprocessing/requirements.txt | 2 +-
.../portability/fn_api_runner/fn_runner_test.py | 3 -
.../runners/portability/portable_runner_test.py | 2 -
.../runners/portability/samza_runner_test.py | 200 ----
.../container/ml/py310/base_image_requirements.txt | 2 +-
.../container/ml/py310/gpu_image_requirements.txt | 2 +-
.../container/ml/py312/base_image_requirements.txt | 6 +-
.../container/ml/py312/gpu_image_requirements.txt | 8 +-
sdks/python/mypy.ini | 110 --
sdks/python/test-suites/gradle.properties | 3 -
sdks/python/test-suites/portable/build.gradle | 6 -
sdks/python/test-suites/portable/common.gradle | 27 -
sdks/python/tox.ini | 7 -
settings.gradle.kts | 2 -
.../www/site/content/en/blog/capability-matrix.md | 2 +-
.../en/contribute/postcommits-policies-details.md | 2 +-
.../site/content/en/documentation/runners/samza.md | 4 +-
.../site/content/en/get-started/beam-overview.md | 5 +-
.../site/content/en/get-started/quickstart-java.md | 21 -
.../content/en/get-started/wordcount-example.md | 43 -
website/www/site/content/en/roadmap/_index.md | 2 +-
website/www/site/content/en/roadmap/go-sdk.md | 2 +-
.../www/site/content/en/roadmap/samza-runner.md | 2 +-
website/www/site/data/capability_matrix.yaml | 34 -
.../layouts/partials/section-menu/en/runners.html | 1 -
218 files changed, 414 insertions(+), 23637 deletions(-)
delete mode 100644 .github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Samza.json
delete mode 100644 .github/workflows/beam_PostCommit_Go_VR_Samza.yml
delete mode 100644 .github/workflows/beam_PostCommit_Java_PVR_Samza.yml
delete mode 100644 .github/workflows/beam_PostCommit_Java_ValidatesRunner_Samza.yml
delete mode 100644 .github/workflows/beam_PostCommit_Python_ValidatesRunner_Samza.yml
delete mode 100644 .github/workflows/beam_PostCommit_XVR_Samza.yml
delete mode 100644 .test-infra/BUILD_STATUS.md
delete mode 100644 runners/samza/build.gradle
delete mode 100644 runners/samza/job-server/build.gradle
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaExecutionContext.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaExecutionEnvironment.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobInvoker.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineExceptionContext.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineLifeCycleListener.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptionsValidator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineResult.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineRunner.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPortablePipelineOptions.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPortablePipelineResult.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunnerOverrideConfigs.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunnerRegistrar.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/TestSamzaRunner.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/container/BeamContainerRunner.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/container/BeamJobCoordinatorRunner.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/container/ContainerCfgLoader.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/container/ContainerCfgLoaderFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/container/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/DoFnRunnerWithMetrics.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/FnWithMetricsWrapper.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaGBKMetricOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaMetricOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaMetricOpFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaMetricsContainer.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaTransformMetricRegistry.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaTransformMetrics.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/AsyncDoFnRunner.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/BundleManager.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/ClassicBundleManager.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnRunnerWithKeyedInternals.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/FutureCollector.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/FutureCollectorImpl.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/GroupByKeyOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedInternals.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KvToKeyedWorkItemOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/Op.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpAdapter.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpEmitter.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OutputManagerFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/PortableBundleManager.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/PortableDoFnOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaAssignContext.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnInvokerRegistrar.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaExecutableStageContextFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaMetricsBundleProgressHandler.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStateRequestHandlers.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SingletonKeyedWorkItem.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/WindowAssignOp.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/state/SamzaMapState.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/state/SamzaSetState.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/state/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/GroupWithoutRepartition.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/UpdatingCombineFn.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigBuilder.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigContext.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/FlattenPCollectionsTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/GroupByKeyTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ImpulseTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PViewToIdMapper.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ReadTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/RedistributeByKeyTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ReshuffleTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaImpulseSystemFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPipelineTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPortablePipelineTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPortableTranslatorRegistrar.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishView.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishViewTransformOverride.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishViewTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamSystemFactory.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTransformOverrides.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTranslatorRegistrar.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SplittableParDoTranslators.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/StateIdParser.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TranslationContext.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/WindowAssignTranslator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/package-info.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/ConfigUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/DoFnUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/FutureUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/HashIdGenerator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/PortableConfigUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/SamzaCoders.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/SamzaPipelineExceptionListener.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/SamzaPipelineTranslatorUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/StateUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/StoreIdGenerator.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/WindowUtils.java
delete mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/package-info.java
delete mode 100644 runners/samza/src/main/resources/log4j.properties
delete mode 100644 runners/samza/src/main/resources/samza-conf.properties
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/SamzaPipelineOptionsValidatorTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystemTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/adapter/TestBoundedSource.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/adapter/TestCheckpointMark.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/adapter/TestSourceHelpers.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/adapter/TestUnboundedSource.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystemTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaRunnerWithTransformMetrics.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaTransformMetricsRegistry.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/AsyncDoFnRunnerTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/ClassicBundleManagerTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/FutureCollectorImplTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/GroupByKeyOpTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/KeyedTimerDataTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/PortableBundleManagerTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/SamzaMetricsBundleProgressHandlerTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternalsTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactoryTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/SdkHarnessDoFnRunnerTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/translation/ConfigGeneratorTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/translation/SamzaImpulseSystemTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/translation/TranslationContextTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/DoFnUtilsTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/FutureUtilsTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/InMemoryMetricsReporter.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/PipelineJsonRendererTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/PortableConfigUtilsTest.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/TestHashIdGenerator.java
delete mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/WindowUtilsTest.java
delete mode 100644 runners/samza/src/test/resources/ExpectedDag.json
delete mode 100644 runners/samza/src/test/resources/log4j-test.properties
delete mode 100644 sdks/go/pkg/beam/runners/samza/samza.go
delete mode 100644 sdks/python/apache_beam/runners/portability/samza_runner_test.py
delete mode 100644 sdks/python/mypy.ini