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 deabcd12185 Disable remote cache when no credential provided (#29446)
add 729c4de416b Fix Dataflow ARM PostCommit failing Java21 (#29444)
add f9b9d9af7b6 [dsl-euphoria] #29451 deprecate Euphoria DSL
add f6189692c9a Merge pull request #29452: [dsl-euphoria] #29451 deprecate
Euphoria DSL
add b995211561e Add logging changes to CHANGES.md (#29442)
add 8ac8b20bcd1 Gcsio migration (#29360)
add 481b434dccc [changes.md] #29451 notice about deprecation of Euphoria
DSL
add a59fe16d619 Merge pull request #29454: [changes.md] #29451 notice
about deprecation of Euphoria DSL
add 6235a0c9f05 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#29449)
add 190237817ba Bump golang.org/x/text from 0.13.0 to 0.14.0 in /sdks
(#29324)
add 8b0edf42489 Add DataflowRunner unit test to guard against change on
important IO transform step names (#29230)
add 977a7d85cad Update beam-master container tag for python (#29457)
add 06265f90877 Update splittable-do-fn.md with links to doc (#29458)
add 5e9ea74c85e Build multi-arch snapshot containers (#29419)
No new revisions were added by this update.
Summary of changes:
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 8 +-
.../tools/stale_dataflow_prebuilt_image_cleaner.sh | 27 +-
CHANGES.md | 6 +-
.../org/apache/beam/gradle/BeamDockerPlugin.groovy | 19 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 5 +
examples/java/build.gradle | 5 +-
.../assets/symbols/python.g.yaml | 8 -
.../google-cloud-dataflow-java/arm/build.gradle | 2 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 119 +
sdks/go.mod | 40 +-
sdks/go.sum | 80 +-
.../core/client/accumulators/Accumulator.java | 3 +
.../client/accumulators/AccumulatorProvider.java | 3 +
.../euphoria/core/client/accumulators/Counter.java | 7 +-
.../core/client/accumulators/Histogram.java | 7 +-
.../euphoria/core/client/accumulators/Timer.java | 3 +
.../accumulators/VoidAccumulatorProvider.java | 3 +
.../core/client/functional/BinaryFunction.java | 2 +
.../core/client/functional/BinaryFunctor.java | 7 +-
.../functional/CombinableBinaryFunction.java | 7 +-
.../functional/CombinableReduceFunction.java | 3 +
.../client/functional/CompositeUnaryFunction.java | 7 +-
.../euphoria/core/client/functional/Consumer.java | 7 +-
.../core/client/functional/ExtractEventTime.java | 6 +-
.../core/client/functional/ReduceFunction.java | 3 +
.../core/client/functional/ReduceFunctor.java | 3 +
.../client/functional/SameArgsBinaryFunction.java | 7 +-
.../euphoria/core/client/functional/Supplier.java | 2 +
.../core/client/functional/TernaryFunction.java | 7 +-
.../core/client/functional/UnaryFunction.java | 2 +
.../core/client/functional/UnaryFunctionEnv.java | 2 +
.../core/client/functional/UnaryFunctor.java | 3 +
.../core/client/functional/UnaryPredicate.java | 7 +-
.../core/client/functional/VoidFunction.java | 7 +-
.../euphoria/core/client/io/Collector.java | 2 +
.../euphoria/core/client/io/Context.java | 7 +-
.../euphoria/core/client/io/Environment.java | 7 +-
.../extensions/euphoria/core/client/lib/Split.java | 3 +
.../core/client/operator/AssignEventTime.java | 3 +
.../core/client/operator/CompositeOperator.java | 2 +
.../euphoria/core/client/operator/CountByKey.java | 3 +
.../euphoria/core/client/operator/Distinct.java | 3 +
.../euphoria/core/client/operator/Filter.java | 3 +
.../euphoria/core/client/operator/FlatMap.java | 3 +
.../euphoria/core/client/operator/FullJoin.java | 3 +
.../euphoria/core/client/operator/Join.java | 3 +
.../euphoria/core/client/operator/LeftJoin.java | 3 +
.../euphoria/core/client/operator/MapElements.java | 3 +
.../euphoria/core/client/operator/ReduceByKey.java | 2 +
.../core/client/operator/ReduceWindow.java | 3 +
.../euphoria/core/client/operator/RightJoin.java | 3 +
.../euphoria/core/client/operator/SumByKey.java | 3 +
.../euphoria/core/client/operator/TopPerKey.java | 3 +
.../euphoria/core/client/operator/Union.java | 3 +
.../core/client/operator/base/Builders.java | 3 +
.../operator/base/OptionalMethodBuilder.java | 2 +
.../core/client/operator/base/WindowAware.java | 2 +
.../core/client/operator/hint/OutputHint.java | 2 +-
.../euphoria/core/client/type/TypeAware.java | 3 +-
.../euphoria/core/client/type/TypeAwareness.java | 2 +
.../euphoria/core/client/type/TypeUtils.java | 7 +-
.../extensions/euphoria/core/client/util/Fold.java | 2 +
.../extensions/euphoria/core/client/util/Max.java | 7 +-
.../core/client/util/PCollectionLists.java | 2 +
.../extensions/euphoria/core/client/util/Sums.java | 7 +-
.../core/translate/BeamAccumulatorProvider.java | 2 +
.../translate/BroadcastHashJoinTranslator.java | 3 +
.../translate/CompositeOperatorTranslator.java | 2 +
.../euphoria/core/translate/EuphoriaOptions.java | 7 +-
.../euphoria/core/translate/FlatMapTranslator.java | 2 +
.../euphoria/core/translate/JoinTranslator.java | 7 +-
.../euphoria/core/translate/OperatorTransform.java | 2 +
.../core/translate/OperatorTranslator.java | 2 +
.../core/translate/ReduceByKeyTranslator.java | 7 +-
.../core/translate/SingleValueContext.java | 3 +
.../core/translate/TimestampExtractTransform.java | 2 +
.../core/translate/TranslatorProvider.java | 7 +-
.../euphoria/core/translate/UnionTranslator.java | 7 +-
.../translate/collector/AdaptableCollector.java | 3 +
.../core/translate/collector/CollectorAdapter.java | 2 +
.../translate/collector/SingleValueCollector.java | 7 +-
.../core/translate/provider/CompositeProvider.java | 2 +
.../provider/GenericTranslatorProvider.java | 3 +
.../sdk/extensions/euphoria/core/util/IOUtils.java | 2 +
.../euphoria/core/util/InstanceUtils.java | 3 +
sdks/java/io/kafka/build.gradle | 5 +
.../examples/complete/game/user_score.py | 1 +
sdks/python/apache_beam/internal/gcp/auth.py | 7 +-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 4 +-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 4 +
.../apache_beam/io/gcp/bigquery_tools_test.py | 5 +-
sdks/python/apache_beam/io/gcp/gcsfilesystem.py | 37 +-
.../io/gcp/gcsfilesystem_integration_test.py | 9 +-
.../apache_beam/io/gcp/gcsfilesystem_test.py | 74 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 643 ++---
.../apache_beam/io/gcp/gcsio_integration_test.py | 188 +-
sdks/python/apache_beam/io/gcp/gcsio_overrides.py | 55 -
sdks/python/apache_beam/io/gcp/gcsio_test.py | 886 ++-----
.../io/gcp/internal/clients/storage/__init__.py | 33 -
.../internal/clients/storage/storage_v1_client.py | 1517 -----------
.../clients/storage/storage_v1_messages.py | 2714 --------------------
.../options/pipeline_options_validator_test.py | 1 +
.../runners/dataflow/internal/apiclient.py | 65 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../apache_beam/runners/interactive/utils.py | 29 +-
.../apache_beam/runners/interactive/utils_test.py | 41 +-
.../runners/portability/sdk_container_builder.py | 42 +-
sdks/python/mypy.ini | 3 -
sdks/python/setup.py | 1 +
.../www/site/content/en/blog/splittable-do-fn.md | 3 +
110 files changed, 1128 insertions(+), 5847 deletions(-)
delete mode 100644 sdks/python/apache_beam/io/gcp/gcsio_overrides.py
delete mode 100644
sdks/python/apache_beam/io/gcp/internal/clients/storage/__init__.py
delete mode 100644
sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py
delete mode 100644
sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py
