This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/gradle/com.avast.gradle-gradle-docker-compose-plugin-0.17.5
in repository https://gitbox.apache.org/repos/asf/beam.git
omit 7b62af122ad Bump com.avast.gradle:gradle-docker-compose-plugin
add 4f2411e999e Revert "[Java Portable SDK] Configure JVM so that it exits
upon OutOfMemoryEr…" (#38567)
add 32ec9bb0946 Bump com.gradle.common-custom-user-data-gradle-plugin
(#38574)
add b9b9e78eeae Bump github.com/nats-io/nats-server/v2 from 2.14.0 to
2.14.1 in /sdks (#38576)
add 930b94cceb6 Fix test hang in subprocess expansion service on port bind
failure (#38572)
add ad93dd5ad64 Install wget and use repo token (#38340)
add 65e8b655195 huggingface model handler for yaml - retry (#38451)
add 707b48d4c6d Fix table row inference benchmark using wrong model path
(#38569)
add 898c1a8e22a Fix flaky MatrixPowerTest.test_basics by reading all
generated shards (#38585)
add 0c9b272c56b Update transform catalogue docs (#38457)
add b6aaf42e92e Initial skeleton for the Delta Lake source (#38571)
add 60620e788f0 Enforce Google Maven Mirror on CI environments (#38586)
add 1c0c02472c7 Adds backlog reporting support for non-fnapi based SDF's.
(#38346)
add 2203c8d4469 [Prism] Fix DEADLINE_EXCEEDED errors caused by worker
failures (#38523)
add 9d307e559eb Suppress log spams in gcsio 3.0 (#38588)
add 8f6e27117e1 Bump golang.org/x/net from 0.54.0 to 0.55.0 in /sdks
(#38595)
add 70d8f7dcfdd Revert "huggingface model handler for yaml - retry
(#38451)" (#38601)
add 63501f33968 Fix data_race condition in WindmillStreamSenderTest
(#38589)
add ef5f89f0508 [Iceberg] Fix manifest bounds being padded with trailing
0x00 bytes (#38580)
add 489efaa2400 Bump docker/build-push-action from 7.1.0 to 7.2.0 (#38597)
add 889ac54b236 Fix cancelled run handling in flaky test prefetcher
(#38579)
add a3e33da209c increase timeout (#38604)
add 978c37542c0 Revert "Bump golangci/golangci-lint-action from 3 to 8
(#36291)" (#38606)
add 590c9c27797 Report source lineage from HadoopFormatIO (#37265)
add 679adb85b14 Pipe Valuekind through DoFn and output builders (#38490)
add 7272ab5e5b8 [Python] Add type_overrides parameter to BigQuery I/O for
custom BigQuery-to-Python type mappings (#37253)
add d901481e851 Update Python Dependencies - manual trigger (#38610)
add db15fff4b9b Count cancelled runs in last-5 flaky check (#38614)
add 361c2c473a8 Reduce python expansion service startup time (#38611)
add bb5c486512d Update action.yml
add 94a9f824768 Bump docker/login-action from 4.1.0 to 4.2.0 (#38627)
add 8a30cc76045 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#38629)
add 35c70e5cb5b Bump docker/setup-buildx-action from 4.0.0 to 4.1.0
(#38628)
add 181424bb68d Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#38630)
add 551a5a0c998 Update cython requirement from <4,>=3.0 to >=3.2.5,<4 in
/sdks/python (#38626)
add 5ad6df9f5a4 Fix flaky test_csv_to_json in Beam YAML SDK (#38617)
add 1858d2ef89a Update go dependencies (#38530)
add 1b261f0a399 Fix Fn API data plane deadlock when outbound queue is full
(#38581)
add 4049f00f165 [yaml] add support for matchall (#38512)
add eb29f866586 Update BEAM_DEV_SDK_CONTAINER_TAG to new version (#38699)
add d553b78ce2f [Dataflow Streaming] Add Operation::finishKey() and move
processTimers into it (#38430)
add 9583fe94755 [Cloud Spanner Change Streams] Fix inverted evaluation of
cancelQueryOnHeartbeat (#38695)
add b91538b4acc Bump cloud.google.com/go/bigtable from 1.47.0 to 1.48.0 in
/sdks (#38703)
add a7d2708d0f5 Bump google.golang.org/api from 0.280.0 to 0.281.0 in
/sdks (#38704)
add 45b79d23f9a Remove redundant HTTP->HTTPS redirect in .htaccess (#38522)
add 852d0720ac0 Refactor _SharedCache to handle context vs non-context
ownership (#38620)
add d2a3cee22e3 Enforce binary-only constraints during early requirements
cache attempts (#38688)
add 5096e63ecae Bump docker/setup-qemu-action from 4.0.0 to 4.1.0 (#38718)
add 3cb68c9bd68 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#38719)
add 758042f0580 Bump google.golang.org/api from 0.281.0 to 0.282.0 in
/sdks (#38720)
add 789b278172c Bump github.com/aws/smithy-go from 1.25.1 to 1.26.0 in
/sdks (#38721)
add 54f7c7dd0d8 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#38722)
add 0302bf5529c Implemented MLTransform generate vocab Dataflow benchmark
(#38215)
add cd8b009d9fc [#38708] Add Flink 2.0 to SDK pipeline options validation
lists (#38726)
add a0494894c35 up timeout (#38732)
add 3f4bcb01570 remove playground annotations from BatchElementsExample
until next release (#38733)
add bdef23f826e Update CHANGES.md after release cut (#38608)
add 3e5a085bd0d Support infer types involving dataclass fields (#38548)
add a32774afe93 [Prism] Fix race condition in element manager (#38734)
add cbab4d7203a Add staged package hashes (#38311)
add d8d4cfc3e11 Updated All Externally Visible Logs/Docs from Runner V2 to
Portable Runner (#38532)
add 3d68e9df172 Bump github.com/aws/aws-sdk-go-v2 from 1.41.7 to 1.41.8 in
/sdks (#38740)
add dc3b2ccf8e3 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#38737)
add 09a1e60fa38 fix race condition in sdb-operator (#38698)
add 5702872d9ae Disable build isolation for pip by default. (#38700)
add 07222b4dac6 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#38741)
add 0a7df5c8ba4 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#38738)
add d9f07c5f6aa Bump setup gradle to allowlisted v6.1.0 (#38745)
add 5a5ef0cc02a Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#38739)
add 6fba3cb34b2 Implement MLTransform One-Hot Encoding benchmark pipeline
(#38404)
add 2b5c1131af3 [yaml] - mongodb write normalization (#38376)
add f771827d9f1 Disable gRPC fork support in
PortableRunnerTestWithSubprocesses (#38744)
add cbc2c21edad Fix flaky
TestDataSampler/GetSamplesForPCollectionsTooManySamples (#38736)
add 44a2ff6146c Re-enable call-args check in yaml_io.py (#38730)
add d00ed0c3834 Bump com.avast.gradle:gradle-docker-compose-plugin
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7b62af122ad)
\
N -- N -- N
refs/heads/dependabot/gradle/com.avast.gradle-gradle-docker-compose-plugin-0.17.5
(d00ed0c3834)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../test-properties.json | 2 +-
.../actions/setup-environment-action/action.yml | 2 +-
.github/build.gradle | 10 +-
..._ValidatesRunner_Dataflow_Streaming_Engine.json | 2 +-
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
.../beam_PostCommit_Python_Versions.json | 2 +-
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 25 +
.../beam_PerformanceTests_SingleStoreIO.yml | 2 +-
.github/workflows/beam_PostCommit_Go.yml | 2 +-
.../workflows/beam_PostCommit_Go_Dataflow_ARM.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow_ARM.yml | 2 +-
.../beam_PostCommit_Java_SingleStoreIO_IT.yml | 2 +-
.github/workflows/beam_PostCommit_Python_Arm.yml | 2 +-
.../beam_PostCommit_XVR_GoUsingJava_Dataflow.yml | 2 +-
.../beam_PostCommit_Yaml_Xlang_Direct.yml | 2 +-
.../workflows/beam_PreCommit_CommunityMetrics.yml | 2 +-
.github/workflows/beam_PreCommit_PythonDocker.yml | 2 +-
.../workflows/beam_PreCommit_Yaml_Xlang_Direct.yml | 2 +-
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 2 +-
...beam_Python_ValidatesContainer_Dataflow_ARM.yml | 2 +-
.github/workflows/build_release_candidate.yml | 4 +-
.github/workflows/build_runner_image.yml | 6 +-
.github/workflows/build_wheels.yml | 2 +-
.github/workflows/finalize_release.yml | 24 +-
..._Dataflow_MLTransform_Generate_Vocab_Batch.txt} | 35 +-
...ataflow_MLTransform_One_Hot_Encoding_Batch.txt} | 18 +-
.../republish_released_docker_containers.yml | 2 +-
.github/workflows/tour_of_beam_backend.yml | 2 +-
.../github/github_runs_prefetcher/code/main.py | 12 +-
.test-infra/tools/refresh_looker_metrics.py | 4 +-
CHANGES.md | 50 +-
buildSrc/build.gradle.kts | 19 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +
.../org/apache/beam/gradle/Repositories.groovy | 22 +-
.../{TopExample.java => BatchElementsExample.java} | 54 +-
gradle.properties | 3 +
...TimeBoundedSplittableProcessElementInvoker.java | 258 +++++----
.../apache/beam/runners/core/SimpleDoFnRunner.java | 21 +
.../core/SplittableParDoViaKeyedWorkItems.java | 9 +
.../core/SplittableProcessElementInvoker.java | 25 +-
.../org/apache/beam/runners/core/StepContext.java | 6 +
...BoundedSplittableProcessElementInvokerTest.java | 47 +-
.../runners/core/SplittableParDoProcessFnTest.java | 124 +++-
.../google-cloud-dataflow-java/arm/build.gradle | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 10 +-
.../beam/runners/dataflow/BatchViewOverrides.java | 10 +-
.../beam/runners/dataflow/DataflowRunner.java | 19 +-
.../dataflow/RedistributeByKeyOverrideFactory.java | 1 +
.../beam/runners/dataflow/util/PackageUtil.java | 3 +
.../beam/runners/dataflow/DataflowRunnerTest.java | 148 ++++-
.../runners/dataflow/util/PackageUtilTest.java | 4 +
.../beam/runners/dataflow/worker/PubsubReader.java | 14 +-
.../worker/SplittableProcessFnFactory.java | 1 +
.../worker/StreamingModeExecutionContext.java | 38 +-
.../dataflow/worker/UngroupedWindmillReader.java | 17 +-
.../dataflow/worker/WindmillKeyedWorkItem.java | 3 +-
.../worker/WindmillReaderIteratorBase.java | 11 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 1 +
.../dataflow/worker/WindmillValueKindHelper.java | 12 +-
.../dataflow/worker/WindowingWindmillReader.java | 2 +
.../WorkerCustomSourceOperationExecutor.java | 3 +
.../dataflow/worker/WorkerCustomSources.java | 9 +-
.../worker/streaming/ComputationWorkExecutor.java | 2 +-
.../util/common/worker/FlattenOperation.java | 3 +
.../worker/util/common/worker/MapTaskExecutor.java | 7 +
.../worker/util/common/worker/Operation.java | 3 +
.../worker/util/common/worker/ParDoOperation.java | 7 +-
.../worker/util/common/worker/ReadOperation.java | 3 +
.../worker/util/common/worker/WorkExecutor.java | 3 +
.../worker/util/common/worker/WriteOperation.java | 3 +
.../client/grpc/GrpcWindmillStreamFactory.java | 6 +-
.../worker/IntrinsicMapTaskExecutorTest.java | 12 +
.../worker/StreamingDataflowWorkerTest.java | 4 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 6 +
.../worker/StreamingModeExecutionContextTest.java | 41 +-
.../worker/WindmillReaderIteratorBaseTest.java | 60 +-
.../dataflow/worker/WorkerCustomSourcesTest.java | 26 +-
.../util/common/worker/ExecutorTestUtils.java | 3 +
.../util/common/worker/MapTaskExecutorTest.java | 12 +
.../util/common/worker/ParDoOperationTest.java | 2 +
.../worker/windmill/src/main/proto/windmill.proto | 2 +-
runners/prism/java/build.gradle | 1 +
sdks/go.mod | 125 ++---
sdks/go.sum | 278 +++++----
.../pkg/beam/core/runtime/exec/datasampler_test.go | 13 +-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 9 +-
sdks/go/pkg/beam/runners/dataflow/dataflow_test.go | 43 +-
.../prism/internal/engine/elementmanager.go | 7 +-
.../beam/runners/prism/internal/environments.go | 93 +--
.../beam/runners/prism/internal/execute_test.go | 21 +
sdks/go/pkg/beam/runners/prism/internal/stage.go | 17 +-
.../beam/runners/prism/internal/testdofns_test.go | 34 ++
.../beam/runners/prism/internal/worker/bundle.go | 58 +-
.../runners/prism/internal/worker/worker_test.go | 67 +++
sdks/java/container/boot.go | 15 +-
.../apache/beam/sdk/transforms/BatchElements.java | 9 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 18 +
.../org/apache/beam/sdk/transforms/DoFnTester.java | 25 +-
.../apache/beam/sdk/transforms/Redistribute.java | 1 +
.../java/org/apache/beam/sdk/transforms/Reify.java | 5 +-
.../org/apache/beam/sdk/transforms/Reshuffle.java | 1 +
.../reflect/ByteBuddyDoFnInvokerFactory.java | 11 +
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 15 +
.../beam/sdk/transforms/reflect/DoFnSignature.java | 26 +
.../sdk/transforms/reflect/DoFnSignatures.java | 8 +
.../construction/SplittableParDoNaiveBounded.java | 11 +
.../org/apache/beam/sdk/values/WindowedValues.java | 3 +-
.../apache/beam/sdk/transforms/ValueKindTest.java | 623 +++++++++++++++++++++
.../apache/beam/sdk/util/WindowedValueTest.java | 33 ++
.../beam/sdk/extensions/gcp/util/GcsUtilV1.java | 9 +
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 31 +-
.../java/{extensions/sbe => io/delta}/build.gradle | 21 +-
.../java/org/apache/beam/sdk/io/delta/DeltaIO.java | 91 +++
.../apache/beam/sdk/io/delta}/package-info.java | 6 +-
.../org/apache/beam/sdk/io/delta/DeltaIOTest.java | 62 ++
sdks/java/io/expansion-service/build.gradle | 1 +
.../action/HeartbeatRecordAction.java | 2 +-
.../SpannerChangeStreamErrorTest.java | 41 +-
.../action/HeartbeatRecordActionTest.java | 4 +-
.../apache/beam/sdk/io/hdfs/HadoopFileSystem.java | 17 +
.../beam/sdk/io/hdfs/HadoopFileSystemTest.java | 20 +
.../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 25 +
.../beam/sdk/io/iceberg/SerializableDataFile.java | 14 +-
.../sdk/io/iceberg/SerializableDataFileTest.java | 65 +++
.../apache/beam/sdk/io/mongodb/MongoDbUtils.java | 74 +++
.../MongoDbWriteSchemaTransformConfiguration.java | 85 +++
.../MongoDbWriteSchemaTransformProvider.java | 168 ++++++
.../beam/sdk/io/mongodb/MongoDbUtilsTest.java | 135 +++++
.../MongoDbWriteSchemaTransformProviderTest.java | 166 ++++++
.../cookbook/ordered_window_elements/streaming.py | 2 +-
.../apache_beam/examples/kafkataxi/README.md | 2 +-
.../apache_beam/examples/matrix_power_test.py | 13 +-
.../apache_beam/examples/ml_transform/README.md | 116 ++++
.../ml_transform/mltransform_generate_vocab.py | 265 +++++++++
.../mltransform_generate_vocab_requirements.txt} | 14 +-
.../mltransform_generate_vocab_test.py | 191 +++++++
.../ml_transform/mltransform_one_hot_encoding.py | 266 +++++++++
.../mltransform_one_hot_encoding_test.py | 259 +++++++++
.../io/external/xlang_bigqueryio_it_test.py | 2 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 25 +-
.../apache_beam/io/gcp/bigquery_schema_tools.py | 63 ++-
.../io/gcp/bigquery_schema_tools_test.py | 109 ++++
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 13 +-
.../apache_beam/io/gcp/bigquery_tools_test.py | 161 ++++++
.../mltransform_tests_requirements.txt} | 15 +-
.../python/apache_beam/options/pipeline_options.py | 2 +-
.../runners/dataflow/dataflow_metrics.py | 2 +-
.../runners/dataflow/dataflow_runner.py | 16 +-
.../runners/dataflow/dataflow_runner_test.py | 20 +
.../runners/dataflow/internal/apiclient.py | 8 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../apache_beam/runners/portability/job_server.py | 5 +
.../runners/portability/portable_runner_test.py | 32 +-
.../runners/portability/prism_runner.py | 10 +-
.../runners/portability/prism_runner_test.py | 11 +
.../apache_beam/runners/portability/stager.py | 149 +++--
.../apache_beam/runners/worker/data_plane.py | 60 +-
.../mltransform_generate_vocab_benchmark.py | 56 ++
.../mltransform_one_hot_encoding_benchmark.py | 197 +++++++
.../inference/table_row_inference_benchmark.py | 44 +-
.../testing/load_tests/dataflow_cost_benchmark.py | 28 +-
sdks/python/apache_beam/testing/test_pipeline.py | 4 +-
sdks/python/apache_beam/transforms/core.py | 4 +-
sdks/python/apache_beam/typehints/opcodes.py | 6 +
sdks/python/apache_beam/typehints/row_type_test.py | 21 +
.../typehints/trivial_inference_test.py | 12 +
sdks/python/apache_beam/utils/subprocess_server.py | 62 +-
.../apache_beam/utils/subprocess_server_test.py | 144 ++++-
sdks/python/apache_beam/yaml/integration_tests.py | 50 ++
sdks/python/apache_beam/yaml/standard_io.yaml | 20 +
.../apache_beam/yaml/standard_providers.yaml | 1 +
sdks/python/apache_beam/yaml/tests/match_all.yaml | 96 ++++
.../yaml/tests/{text.yaml => mongodb.yaml} | 35 +-
sdks/python/apache_beam/yaml/yaml_io.py | 111 +++-
sdks/python/apache_beam/yaml/yaml_io_test.py | 118 ++++
.../python/apache_beam/yaml/yaml_transform_test.py | 2 +-
sdks/python/container/boot.go | 10 +-
.../container/ml/py310/base_image_requirements.txt | 139 ++---
.../container/ml/py310/gpu_image_requirements.txt | 243 ++++----
.../container/ml/py311/base_image_requirements.txt | 139 ++---
.../container/ml/py311/gpu_image_requirements.txt | 241 ++++----
.../container/ml/py312/base_image_requirements.txt | 139 +++--
.../container/ml/py312/gpu_image_requirements.txt | 239 ++++----
.../container/ml/py313/base_image_requirements.txt | 139 +++--
.../container/py310/base_image_requirements.txt | 123 ++--
.../container/py311/base_image_requirements.txt | 125 +++--
.../container/py312/base_image_requirements.txt | 123 ++--
.../container/py313/base_image_requirements.txt | 125 ++---
.../container/py314/base_image_requirements.txt | 121 ++--
sdks/python/pyproject.toml | 2 +-
sdks/standard_external_transforms.yaml | 32 +-
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
settings.gradle.kts | 18 +-
.../transforms/java/aggregation/batchelements.md | 31 +
.../en/documentation/transforms/java/overview.md | 1 +
website/www/site/content/en/performance/_index.md | 2 +
.../_index.md | 22 +-
.../en/performance/mltransformvocab/_index.md | 37 ++
website/www/site/data/performance.yaml | 33 ++
.../partials/section-menu/en/documentation.html | 1 +
website/www/site/static/.htaccess | 14 -
201 files changed, 7105 insertions(+), 1781 deletions(-)
copy
.github/workflows/load-tests-pipeline-options/{beam_Inference_Python_Benchmarks_Dataflow_VLLM_Gemma_Batch.txt
=>
beam_Inference_Python_Benchmarks_Dataflow_MLTransform_Generate_Vocab_Batch.txt}
(66%)
copy
.github/workflows/load-tests-pipeline-options/{beam_Inference_Python_Benchmarks_Dataflow_Pytorch_Language_Modeling_Bert_Large_Uncased.txt
=>
beam_Inference_Python_Benchmarks_Dataflow_MLTransform_One_Hot_Encoding_Batch.txt}
(73%)
copy examples/java/src/main/java/org/apache/beam/examples/{TopExample.java =>
BatchElementsExample.java} (61%)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueKindUtil.java =>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillValueKindHelper.java
(78%)
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ValueKindTest.java
copy sdks/java/{extensions/sbe => io/delta}/build.gradle (66%)
create mode 100644
sdks/java/io/delta/src/main/java/org/apache/beam/sdk/io/delta/DeltaIO.java
copy sdks/java/io/{debezium/src/main/java/org/apache/beam/io/debezium =>
delta/src/main/java/org/apache/beam/sdk/io/delta}/package-info.java (86%)
create mode 100644
sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaIOTest.java
create mode 100644
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbUtils.java
create mode 100644
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbWriteSchemaTransformConfiguration.java
create mode 100644
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbWriteSchemaTransformProvider.java
create mode 100644
sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbUtilsTest.java
create mode 100644
sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbWriteSchemaTransformProviderTest.java
create mode 100644 sdks/python/apache_beam/examples/ml_transform/README.md
create mode 100644
sdks/python/apache_beam/examples/ml_transform/mltransform_generate_vocab.py
copy
sdks/python/apache_beam/{ml/inference/table_row_inference_requirements.txt =>
examples/ml_transform/mltransform_generate_vocab_requirements.txt} (70%)
create mode 100644
sdks/python/apache_beam/examples/ml_transform/mltransform_generate_vocab_test.py
create mode 100644
sdks/python/apache_beam/examples/ml_transform/mltransform_one_hot_encoding.py
create mode 100644
sdks/python/apache_beam/examples/ml_transform/mltransform_one_hot_encoding_test.py
copy
sdks/python/apache_beam/ml/{inference/table_row_inference_requirements.txt =>
transforms/mltransform_tests_requirements.txt} (70%)
create mode 100644
sdks/python/apache_beam/testing/benchmarks/inference/mltransform_generate_vocab_benchmark.py
create mode 100644
sdks/python/apache_beam/testing/benchmarks/inference/mltransform_one_hot_encoding_benchmark.py
create mode 100644 sdks/python/apache_beam/yaml/tests/match_all.yaml
copy sdks/python/apache_beam/yaml/tests/{text.yaml => mongodb.yaml} (62%)
create mode 100644
website/www/site/content/en/documentation/transforms/java/aggregation/batchelements.md
copy website/www/site/content/en/performance/{pytorchresnet152 =>
mltransformonehot}/_index.md (50%)
create mode 100644
website/www/site/content/en/performance/mltransformvocab/_index.md
