This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from a04682a71a9 Merge pull request #24215: Fix OrderedListState for
Dataflow Streaming pipelines on SE.
add f82aac7ac60 [Playground] Use current Go SDK by default (#24256)
add c4cad83442a Fix dashboard links
add c7a0c1b856c Bump github.com/aws/aws-sdk-go-v2/config from 1.18.1 to
1.18.2 in /sdks (#24282)
add 7e9d99f26f4 Add warning about google-cloud-platform-core dependency
change in #24235 (#24295)
add 91473c0579a Add GetSize implementation for DetectNewPartitions SDF
(#23997)
add a2d33ce759c Add ZstdCoder to wrap coders with Zstandard compression
(#24093)
add 8323be62ecc [#24261] Update to objsize 0.6.1 (#24262)
add 4269e8a7ef7 Create template for failing tests. (#21728)
add 814a5ded8c4 Add record_metrics argument to utils.BatchElements (#23701)
add e6e832b62ec Performance test parameters followup fix (#24291)
add ffbb3362d65 Work around coders bug on Dataflow.
add 34f6ae6ae5f Add a test runner for running multiple pipelines in
parallel.
add b692d6f2a8b Run tests as single Dataflow pipeline.
add 26d4021a36c Github hook for dataflow pipelines.
add 15c6da28d62 Guard dataflow run against GCP credentials.
add 177f9b9b388 Guard running of precommit against having variables set.
add 79b8c154b58 Merge pull request #24023 Add a Dataflow smoke test.
add be346e619b0 [Website] add lazy loading attr to images #24250
add 4d5937b9a3d Merge pull request #24251: [Website] add lazy loading attr
to images
add 88c1f0a486b Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#24280)
add 22c52d34b3f Copy editing the machine learning pages (#24301)
add b5ad9f039ca TensorRT Custom Inference Function Implementation (#24039)
add 883a362c930 Teach Azure Filesystem to authenticate using
DefaultAzureCredential in the Python SDK (#24212)
add 61e19e4d7ac Fix mvn command to refer the GCP_REGION variable
add fe4a98a9b3f Merge pull request #24302: Fix mvn command to refer the
GCP_REGION variable
add 67e2008c0ee Add retry to test connections (#23757)
add 9da27671cdc [#24266] Update release candidate script to use
-PisRelease (#24269)
add 0a91d139dea Golang SpannerIO Implementation (#23285)
add 71c6e314d27 Add rootCaCertificate option to SplunkIO (#24229)
add 7ddf55a545c fixed typo
add 0c6d147409d Merge pull request #24315: fixed typo
add f8c57d6cc1a [Website] change share-your-story link, add text to
ADD_CASE_STUDY.md, add video to some case-studies
add d93ece1d0ed Merge pull request #23958: [Website] update share button
and ADD_CASE_STUDY.md
add 2c3973311eb pg_23865 fix selected example at list
add e61cd6a57c9 Expand all categories that contain a selected example
(#23865)
add c49571c61e4 Merge pull request #24231: Fixed display of the selected
example
add 9bad75f1fee [Playground] Remove example bucket (#24198)
add 730b391f29c Extract Go and Python Beam symbols for Playground (#23378)
add 4f1dcfb224d Dask runner tests action (#24324)
add 5802c77d383 Add a portable runner that renders pipelines as a dot
graph.
add c1d82dbfff2 Add basic tests for render runner.
add c01d63096b7 Add the ability to pass a pipeline proto directly.
add f179587039f lint
add 4c2c78def15 Fix typo.
add 63e566ffc79 Serve the graph when output file is not specified.
add 2002d9c3927 Serve the graph when output file is not specified.
add 3db0ac9ba36 Fix parsing of standalone protos.
add ad3e5242f7b Support reading from GCS.
add 7285242cb83 Add text logging.
add 6749fc01647 fix typo.
add e3ab5e75ae5 Some lint and yapf.
add 5c8026671f2 Fix dot detection logic.
add 38e0e3b3397 fix error detected by lint
add 20f60443f46 Make gcs an optional dependency.
add 42ea58fb276 return rather than sys.exit
add a88784e1442 lint
add d57812a3860 Apply suggestions from code review
add e625c317bfb More cleanup, mypy.
add de117c5940c lint
add cf904dc72aa Merge pull request #24037 Add a portable runner that
renders pipelines as a dot graph.
add 8baae457744 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#24318)
add 24f10b5888d [Website] update table text content overflow #23460
add a440fd600fc Merge pull request #23462: [Website] Update pages with
table content overflow
add 9bfffb78b09 [Metrics] Add 'performance tests' tag to JMH dashboard
(related to #22238)
add c0a328ffa77 Merge pull request #24335: [Metrics] Add 'performance
tests' tag to JMH dashboard
add 9f2f135df02 Update apache beam installation in notebook (#24336)
add 00828db664f Adds GCP core dependency to the test expansion service
(#24308)
add e0d0a72f559 [Spark dataset runner] Fix translation to run in the
evaluation thread as well so exceptions are handled properly (closes #24330)
add 84d47ef4a2f Merge pull request #24331: [Spark dataset runner] Fix
handling of exceptions during translation
add d2211bd6c76 Update dataflow containers to coincide with objsize 0.6.1
update (#24326)
add 80311d06870 Add test configurations for deterministic outputs on
Dataflow (#24325)
add 23e59afce97 Updates ExpansionService to support dynamically
discovering and expanding SchemaTransforms (#23413)
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/failing_test.yml | 175 +
.github/issue-rules.yml | 6 +
.github/workflows/dask_runner_tests.yml | 104 +
.../workflows/playground_examples_ci_reusable.yml | 17 +-
.github/workflows/typescript_tests.yml | 68 +
.gitignore | 7 +-
.../job_InferenceBenchmarkTests_Python.groovy | 30 +-
.../job_PerformanceTests_FileBasedIO_Python.groovy | 4 +-
.../job_PerformanceTests_SingleStoreIO.groovy | 2 +-
.../perftests_metrics/Java_JMH_benchmarks.json | 6 +-
.../Python_ML_RunInference_Benchmark_Tests.json | 26 +-
CHANGES.md | 7 +
build.gradle.kts | 12 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 10 +-
examples/multi-language/README.md | 2 +-
.../notebooks/beam-ml/run_inference_pytorch.ipynb | 22 +-
.../run_inference_pytorch_tensorflow_sklearn.ipynb | 74 +-
.../notebooks/beam-ml/run_inference_sklearn.ipynb | 52 +-
.../frontend/lib/assets/assets.gen.dart | 132 +
.../lib/components/login/login_content.dart | 2 +-
.../frontend/lib/components/profile/avatar.dart | 2 +-
.../lib/components/profile/profile_content.dart | 2 +-
.../frontend/lib/models/unit_content.g.dart | 16 +
.../lib/pages/tour/widgets/group_title.dart | 2 +-
.../frontend/lib/pages/tour/widgets/unit.dart | 2 +-
.../frontend/lib/pages/welcome/screen.dart | 2 +-
.../models/get_content_tree_response.g.dart | 16 +
.../repositories/models/get_sdks_response.g.dart | 14 +
.../frontend/lib/repositories/models/group.g.dart | 15 +
.../frontend/lib/repositories/models/module.g.dart | 24 +
.../frontend/lib/repositories/models/node.g.dart | 23 +
.../frontend/lib/repositories/models/unit.g.dart | 13 +
learning/tour-of-beam/frontend/pubspec.yaml | 2 +-
.../job_management/v1/beam_expansion_api.proto | 28 +
.../model/pipeline/v1/external_transforms.proto | 17 +
playground/backend/containers/go/Dockerfile | 33 +-
playground/backend/containers/go/build.gradle | 21 +-
playground/backend/containers/go/setup_sdk.sh | 47 +
playground/backend/containers/python/build.gradle | 10 +-
playground/frontend/Dockerfile | 18 +-
playground/frontend/README.md | 140 +-
playground/frontend/build.gradle | 59 +-
.../config.example.dart} | 25 +-
playground/frontend/lib/main.dart | 2 +
.../example_list/category_expansion_panel.dart | 4 +-
.../example_list/expansion_panel_item.dart | 2 +-
.../playground_components/assets/symbols/go.g.yaml | 6553 ++++++++++
.../assets/symbols/python.g.yaml | 12128 +++++++++++++++++++
.../playground_components/build.gradle.kts | 97 +-
.../lib/playground_components.dart | 5 +-
.../lib/src/assets/assets.gen.dart | 145 +
.../lib/src/controllers/playground_controller.dart | 16 +
.../controllers/snippet_editing_controller.dart | 30 +-
.../playground_components.dart => locator.dart} | 12 +-
.../lib/src/models/sdk.g.dart | 12 +
.../symbols_dictionary.dart} | 14 +-
.../lib/src/notifications/notification.dart | 2 +-
.../src/{constants => }/playground_components.dart | 6 +
.../symbols/loaders/abstract.dart} | 12 +-
.../symbols/loaders/map.dart} | 30 +-
.../lib/src/services/symbols/loaders/yaml.dart | 69 +
.../lib/src/services/symbols/symbols_notifier.dart | 53 +
.../lib/src/widgets/drag_handle.dart | 4 +-
.../lib/src/widgets/logo.dart | 4 +-
.../lib/src/widgets/reset_button.dart | 4 +-
.../lib/src/widgets/toggle_theme_button.dart | 4 +-
.../lib/src/widgets/toggle_theme_icon_button.dart | 28 +-
.../frontend/playground_components/pubspec.yaml | 8 +-
.../src/common/example_repository_mock.mocks.dart | 142 +
.../http_example_loader_test.mocks.dart | 284 +
.../controllers/playground_controller_test.dart | 9 +-
.../playground_controller_test.mocks.dart | 357 +
.../repositories/code_repository_test.mocks.dart | 139 +
.../example_repository_test.mocks.dart | 165 +
.../src/services/symbols/loaders/yaml_test.dart | 63 +
.../services/symbols/symbols_notifier_test.dart | 59 +
.../playground_components/test/tools/common.dart | 90 +
.../extract_symbols_go_test.dart} | 24 +-
.../test/tools/extract_symbols_go/go.golden.yaml | 17 +
.../extract_symbols_go/sdk_mock/directory/file2.go | 19 +
.../sdk_mock/directory/ignore.txt | 18 +
.../tools/extract_symbols_go/sdk_mock/file1.go | 73 +
.../extract_symbols_python_test.dart} | 23 +-
.../extract_symbols_python/python.golden.yaml | 9 +
.../sdk_mock/directory/file2.py | 17 +
.../tools/extract_symbols_python/sdk_mock/file1.py | 47 +
.../tools/extract_symbols_go/extract_symbols_go.go | 257 +
.../tools/extract_symbols_go/go.mod | 20 +
.../tools/extract_symbols_go/go.sum | 3 +
.../extract_symbols_python.py | 124 +
playground/frontend/pubspec.lock | 11 +-
playground/frontend/pubspec.yaml | 1 +
.../states/example_selector_state_test.mocks.dart | 67 +
playground/terraform/README.md | 1 -
.../terraform/infrastructure/buckets/main.tf | 32 -
.../terraform/infrastructure/buckets/output.tf | 31 -
.../terraform/infrastructure/buckets/variables.tf | 38 -
playground/terraform/infrastructure/main.tf | 14 +-
playground/terraform/infrastructure/variables.tf | 17 -
playground/terraform/main.tf | 4 -
playground/terraform/output.tf | 25 -
playground/terraform/variables.tf | 18 -
.../src/main/scripts/build_release_candidate.sh | 4 +-
.../SparkStructuredStreamingPipelineResult.java | 7 +-
.../SparkStructuredStreamingRunner.java | 58 +-
sdks/go.mod | 12 +-
sdks/go.sum | 27 +-
sdks/go/pkg/beam/io/spannerio/spanner.go | 241 +
sdks/go/pkg/beam/io/spannerio/spanner_test.go | 249 +
sdks/java/core/build.gradle | 1 +
.../java/org/apache/beam/sdk/coders/ZstdCoder.java | 179 +
.../org/apache/beam/sdk/coders/ZstdCoderTest.java | 169 +
.../apache/beam/sdk/io/CompressedSourceTest.java | 2 +-
.../sdk/expansion/service/ExpansionService.java | 75 +-
.../ExpansionServiceSchemaTransformProvider.java | 144 +
...xpansionServiceSchemaTransformProviderTest.java | 486 +
.../beam/sdk/io/common/DatabaseTestHelper.java | 42 +-
.../io/gcp/bigquery/BigQueryResourceNaming.java | 2 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 36 +-
.../changestreams/ChangeStreamsConstants.java | 30 +
.../changestreams/action/ActionFactory.java | 15 +-
.../action/ChildPartitionsRecordAction.java | 21 +-
.../action/DataChangeRecordAction.java | 40 +-
.../action/DetectNewPartitionsAction.java | 16 +-
.../action/HeartbeatRecordAction.java | 6 +-
.../action/QueryChangeStreamAction.java | 37 +-
.../changestreams/dao/PartitionMetadataDao.java | 25 +
.../dofn/DetectNewPartitionsDoFn.java | 40 +-
.../dofn/PostProcessingMetricsDoFn.java | 9 +-
.../dofn/ReadChangeStreamPartitionDoFn.java | 56 +-
.../estimator/BytesThroughputEstimator.java | 149 +
.../changestreams/estimator/EncodingException.java | 16 +-
.../estimator/NullThroughputEstimator.java | 59 +
.../changestreams/estimator/SizeEstimator.java | 68 +
.../estimator/ThroughputEstimator.java | 43 +-
.../changestreams/estimator/package-info.java | 14 +-
.../restriction/ThroughputEstimator.java | 115 -
.../restriction/TimestampRangeTracker.java | 10 +-
.../action/DataChangeRecordActionTest.java | 20 +-
.../action/DetectNewPartitionsActionTest.java | 134 +
.../action/QueryChangeStreamActionTest.java | 51 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 18 +-
.../estimator/BytesThroughputEstimatorTest.java | 176 +
.../estimator/NullThroughputEstimatorTest.java | 33 +-
.../restriction/ThroughputEstimatorTest.java | 155 -
.../beam/sdk/io/splunk/CustomX509TrustManager.java | 98 +
.../beam/sdk/io/splunk/HttpEventPublisher.java | 53 +-
.../beam/sdk/io/splunk/SplunkEventWriter.java | 46 +-
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 65 +-
.../sdk/io/splunk/CustomX509TrustManagerTest.java | 80 +
.../beam/sdk/io/splunk/HttpEventPublisherTest.java | 119 +-
.../test/resources/SplunkTestCerts/PrivateKey.pem | 28 +
.../SplunkTestCerts/RecognizedCertificate.crt.txt | 26 +
.../test/resources/SplunkTestCerts/RootCA.crt.txt | 31 +
.../resources/SplunkTestCerts/RootCA_2.crt.txt | 13 +
.../SplunkTestCerts/RootCA_PrivateKey.pem | 52 +
.../UnrecognizedCertificate.crt.txt | 21 +
sdks/java/testing/expansion-service/build.gradle | 1 +
.../apache_beam/internal/{ => azure}/__init__.py | 0
sdks/python/apache_beam/internal/azure/auth.py | 83 +
.../apache_beam/io/azure/blobstoragefilesystem.py | 28 +-
.../io/azure/blobstoragefilesystem_test.py | 24 +-
sdks/python/apache_beam/io/azure/blobstorageio.py | 17 +-
.../io/azure/integration_test/Dockerfile | 46 +
.../integration_test/azure_integration_test.sh | 79 +
.../io/azure/integration_test/docker-compose.yml | 50 +
.../apache_beam/io/azure/integration_test/ssl.conf | 37 +
.../apache_beam/ml/inference/tensorrt_inference.py | 93 +-
.../ml/inference/tensorrt_inference_test.py | 98 +
.../python/apache_beam/options/pipeline_options.py | 29 +
sdks/python/apache_beam/pipeline.py | 3 +-
sdks/python/apache_beam/portability/common_urns.py | 1 +
.../runners/dataflow/dataflow_runner.py | 4 +
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
.../runners/portability/fn_api_runner/fn_runner.py | 4 +
.../portability/fn_api_runner/translations.py | 16 +-
.../runners/portability/local_job_service.py | 8 +-
sdks/python/apache_beam/runners/render.py | 537 +
sdks/python/apache_beam/runners/render_test.py | 89 +
.../testing/benchmarks/inference/README.md | 24 +-
sdks/python/apache_beam/transforms/external.py | 158 +-
.../python/apache_beam/transforms/external_test.py | 30 +
sdks/python/apache_beam/transforms/util.py | 28 +-
sdks/python/apache_beam/transforms/util_test.py | 35 +-
.../container/py310/base_image_requirements.txt | 2 +-
.../container/py37/base_image_requirements.txt | 2 +-
.../container/py38/base_image_requirements.txt | 2 +-
.../container/py39/base_image_requirements.txt | 2 +-
sdks/python/scripts/run_pylint.sh | 1 +
sdks/python/setup.py | 4 +-
sdks/python/test-suites/direct/common.gradle | 9 +
sdks/python/tox.ini | 37 +
.../src/apache_beam/internal/pipeline.ts | 12 +-
.../typescript/src/apache_beam/runners/dataflow.ts | 2 +-
.../src/apache_beam/runners/direct_runner.ts | 7 +-
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
.../apache_beam/runners/portable_runner/runner.ts | 4 +-
sdks/typescript/src/apache_beam/runners/runner.ts | 11 +-
.../src/apache_beam/runners/universal.ts | 2 +-
.../apache_beam/testing/multi_pipeline_runner.ts | 157 +
.../typescript/src/apache_beam/worker/operators.ts | 2 +-
sdks/typescript/src/apache_beam/worker/worker.ts | 25 +-
sdks/typescript/test/primitives_test.ts | 48 +
website/ADD_CASE_STUDY.md | 1 +
website/www/site/content/en/case-studies/intuit.md | 5 +
.../www/site/content/en/case-studies/ricardo.md | 5 +
.../content/en/community/presentation-materials.md | 2 +-
.../dsls/sql/calcite/lexical-structure.md | 2 +
.../documentation/dsls/sql/zetasql/data-types.md | 24 +-
.../en/documentation/dsls/sql/zetasql/lexical.md | 10 +-
.../en/documentation/dsls/sql/zetasql/operators.md | 12 +-
.../documentation/dsls/sql/zetasql/query-syntax.md | 12 +-
.../en/documentation/ml/anomaly-detection.md | 117 +-
.../content/en/documentation/ml/data-processing.md | 34 +-
.../en/documentation/ml/multi-model-pipelines.md | 38 +-
.../en/documentation/ml/online-clustering.md | 121 +-
.../content/en/documentation/ml/orchestration.md | 94 +-
.../site/content/en/documentation/ml/overview.md | 63 +-
.../en/documentation/ml/runinference-metrics.md | 54 +-
website/www/site/layouts/case-studies/list.html | 8 +-
.../www/site/layouts/partials/quotes/quote.html | 2 +-
.../shortcodes/community/table_with_icons.html | 2 +
222 files changed, 27387 insertions(+), 1549 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/failing_test.yml
create mode 100644 .github/workflows/dask_runner_tests.yml
create mode 100644 learning/tour-of-beam/frontend/lib/assets/assets.gen.dart
create mode 100644
learning/tour-of-beam/frontend/lib/models/unit_content.g.dart
create mode 100644
learning/tour-of-beam/frontend/lib/repositories/models/get_content_tree_response.g.dart
create mode 100644
learning/tour-of-beam/frontend/lib/repositories/models/get_sdks_response.g.dart
create mode 100644
learning/tour-of-beam/frontend/lib/repositories/models/group.g.dart
create mode 100644
learning/tour-of-beam/frontend/lib/repositories/models/module.g.dart
create mode 100644
learning/tour-of-beam/frontend/lib/repositories/models/node.g.dart
create mode 100644
learning/tour-of-beam/frontend/lib/repositories/models/unit.g.dart
create mode 100755 playground/backend/containers/go/setup_sdk.sh
copy
playground/frontend/{playground_components/lib/src/constants/playground_components.dart
=> lib/config.example.dart} (51%)
create mode 100644
playground/frontend/playground_components/assets/symbols/go.g.yaml
create mode 100644
playground/frontend/playground_components/assets/symbols/python.g.yaml
create mode 100644
playground/frontend/playground_components/lib/src/assets/assets.gen.dart
copy
playground/frontend/playground_components/lib/src/{constants/playground_components.dart
=> locator.dart} (68%)
create mode 100644
playground/frontend/playground_components/lib/src/models/sdk.g.dart
copy
playground/frontend/playground_components/lib/src/{constants/playground_components.dart
=> models/symbols_dictionary.dart} (68%)
copy playground/frontend/playground_components/lib/src/{constants =>
}/playground_components.dart (91%)
copy
playground/frontend/playground_components/lib/src/{constants/playground_components.dart
=> services/symbols/loaders/abstract.dart} (68%)
copy playground/frontend/playground_components/lib/src/{widgets/logo.dart =>
services/symbols/loaders/map.dart} (63%)
create mode 100644
playground/frontend/playground_components/lib/src/services/symbols/loaders/yaml.dart
create mode 100644
playground/frontend/playground_components/lib/src/services/symbols/symbols_notifier.dart
create mode 100644
playground/frontend/playground_components/test/src/common/example_repository_mock.mocks.dart
create mode 100644
playground/frontend/playground_components/test/src/controllers/example_loaders/http_example_loader_test.mocks.dart
create mode 100644
playground/frontend/playground_components/test/src/controllers/playground_controller_test.mocks.dart
create mode 100644
playground/frontend/playground_components/test/src/repositories/code_repository_test.mocks.dart
create mode 100644
playground/frontend/playground_components/test/src/repositories/example_repository_test.mocks.dart
create mode 100644
playground/frontend/playground_components/test/src/services/symbols/loaders/yaml_test.dart
create mode 100644
playground/frontend/playground_components/test/src/services/symbols/symbols_notifier_test.dart
create mode 100644
playground/frontend/playground_components/test/tools/common.dart
copy
playground/frontend/playground_components/{lib/src/constants/playground_components.dart
=> test/tools/extract_symbols_go/extract_symbols_go_test.dart} (67%)
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_go/go.golden.yaml
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_go/sdk_mock/directory/file2.go
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_go/sdk_mock/directory/ignore.txt
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_go/sdk_mock/file1.go
copy
playground/frontend/playground_components/{lib/src/constants/playground_components.dart
=> test/tools/extract_symbols_python/extract_symbols_python_test.dart} (67%)
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_python/python.golden.yaml
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_python/sdk_mock/directory/file2.py
create mode 100644
playground/frontend/playground_components/test/tools/extract_symbols_python/sdk_mock/file1.py
create mode 100644
playground/frontend/playground_components/tools/extract_symbols_go/extract_symbols_go.go
create mode 100644
playground/frontend/playground_components/tools/extract_symbols_go/go.mod
create mode 100644
playground/frontend/playground_components/tools/extract_symbols_go/go.sum
create mode 100644
playground/frontend/playground_components/tools/extract_symbols_python/extract_symbols_python.py
create mode 100644
playground/frontend/test/pages/playground/states/example_selector_state_test.mocks.dart
delete mode 100644 playground/terraform/infrastructure/buckets/main.tf
delete mode 100644 playground/terraform/infrastructure/buckets/output.tf
delete mode 100644 playground/terraform/infrastructure/buckets/variables.tf
create mode 100644 sdks/go/pkg/beam/io/spannerio/spanner.go
create mode 100644 sdks/go/pkg/beam/io/spannerio/spanner_test.go
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ZstdCoder.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/coders/ZstdCoderTest.java
create mode 100644
sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionServiceSchemaTransformProvider.java
create mode 100644
sdks/java/expansion-service/src/test/java/org/apache/beam/sdk/expansion/service/ExpansionServiceSchemaTransformProviderTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/BytesThroughputEstimator.java
copy
playground/frontend/playground_components/lib/src/constants/playground_components.dart
=>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/EncodingException.java
(67%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/NullThroughputEstimator.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/SizeEstimator.java
copy
playground/frontend/playground_components/lib/src/widgets/drag_handle.dart =>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/ThroughputEstimator.java
(50%)
rename
playground/frontend/playground_components/lib/src/constants/playground_components.dart
=>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/package-info.java
(67%)
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/ThroughputEstimator.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsActionTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/BytesThroughputEstimatorTest.java
copy
playground/frontend/playground_components/lib/src/widgets/drag_handle.dart =>
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/estimator/NullThroughputEstimatorTest.java
(51%)
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/ThroughputEstimatorTest.java
create mode 100644
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/CustomX509TrustManager.java
create mode 100644
sdks/java/io/splunk/src/test/java/org/apache/beam/sdk/io/splunk/CustomX509TrustManagerTest.java
create mode 100644
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/PrivateKey.pem
create mode 100644
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RecognizedCertificate.crt.txt
create mode 100644
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RootCA.crt.txt
create mode 100644
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RootCA_2.crt.txt
create mode 100644
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RootCA_PrivateKey.pem
create mode 100644
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/UnrecognizedCertificate.crt.txt
copy sdks/python/apache_beam/internal/{ => azure}/__init__.py (100%)
create mode 100644 sdks/python/apache_beam/internal/azure/auth.py
create mode 100644 sdks/python/apache_beam/io/azure/integration_test/Dockerfile
create mode 100755
sdks/python/apache_beam/io/azure/integration_test/azure_integration_test.sh
create mode 100644
sdks/python/apache_beam/io/azure/integration_test/docker-compose.yml
create mode 100644 sdks/python/apache_beam/io/azure/integration_test/ssl.conf
create mode 100644 sdks/python/apache_beam/runners/render.py
create mode 100644 sdks/python/apache_beam/runners/render_test.py
create mode 100644
sdks/typescript/src/apache_beam/testing/multi_pipeline_runner.ts
