This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/sdks/google.golang.org/api-0.269.0
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 2eb4c7d3509 Bump google.golang.org/api from 0.257.0 to 0.269.0 in /sdks
add e761581b30d Reduce Fn Runner changes
add 4739405cdbc Merge pull request #37727: [Drain] Reduce Fn Runner changes
add 1430241b6fe Pin aircompressor. (#37737)
add 3197d88ef5c Update java containers. (#37733)
add c9ab4b6ae8d Add default_pickle_library_override delegation to
InteractiveRunner (#37752)
add e5db1b3c63e [Dataflow Java Streaming] Reset state using finally blocks
instead of catching Exception, in cases where it may otherwise corrupt
datastructures if an OutOfMemoryError is thrown. (#37746)
add e1e0637d989 [ErrorProne] Fix FormatStringShouldUsePlaceholders string
concat when Preconditions is used (#37745)
add eb5f9950c4a [Direct Runner] Fix test failure and logging configuration
by ensuring overridden Loggers are not garbaged collected (#37763)
add 7ba0efd4d24 [ErrorProne] Enable `MutablePublicArray` Error Prone Check
(#37761)
add 38b416cfb63 update java container version (#37756)
add d42111cd019 Merge pull request #37748: Where a Throwable is being
caught, take care to rethrow OutOfMemoryError
add 505ac1a9b22 Fix MissingSummary errorprone Warnings Across Codebase
add e7a97c26893 Fix MissingSummary errorprone Warnings Across Codebase
(#37759)
add 96306945ad6 refactor: Remove redundant protected access modifiers and
enable the `ProtectedMembersInFinalClass` ErrorProne check. (#37757)
add dfc0bd12021 Enable UseCorrectAssertInTests ErrorProne Check (#37766)
add 298f3090920 Fix InlineFormatString Error Prone checks (#37768)
add e28ed02b9b8 Add Apache Beam installation to Dockerfile
add 08af69c65f6 Install setuptools for playground cd examples
add f682a85fbbe Merge pull request #37619 from
apache/playground-interactive
add 828914840df [Dataflow Java Streaming] Ensure that OutOfMemoryError
triggers JVM shutdown instead of being retried. This matches MemoryMonitor
detection of gc thrashing and prevents workers from remaining in broken state
that may be fixed by restarting (#37749)
add b42c992c7d4 [ErrorProne] Fix BadInstanceof and enable check (#37753)
add 676c998dec7 Enable StringCharset Error Prone Check (#37767)
add 94c39272196 refactor: replace lambda expressions with method references
add 52c6603a8fe Merge pull request #37765: [ErrorProne] Fix
UnnecessaryLambda Error Prone issues
add 500996fbf99 Remove LongDoubleConversion from ErrorProne disabledChecks
add 1317aa0b777 Fix LongDoubleConversion warnings
add d2fead7c692 Merge pull request #37769: [ErrorProne] Enable
LongDoubleConversion check
add 8ee8b10b7f1 Add more ParquetIo write options (#37740)
add b6bc9040954 Merge pull request #37715: Disable combiner lifting only
for count triggers
add 927ee2c4835 fix: Correct malformed Javadoc tags and update Error Prone
configuration. (#37755)
add 78061b82a24 If the partition count or kafka IO size is large, then
skip committin… (#37510)
add 4d9e7fc77f7 Fix flaky TextIOWriteTest by loosening the shard count.
Records may end up in the same shard as other records as it is random.
Simplify the test to use Iterables instead of arrays.
add 95d848167db Merge pull request #37798: Fix flaky TextIOWriteTest by
loosening the shard count
add 590684f81b0 Exclude vertex_ai_postcommit tests from embeddings dep
suite
add 417922c2f04 centralize skipping vertex ai test
add 81fe00cff1e Fix pylint vertex ai test
add d64c21493d5 remove RUN_VERTEX_AI_TESTS flag
add 0f805b56d3b Use pytest.importorskip for Vertex AI tests & remove
vertex_ai_skip helper
add ea473d22b2b Merge pull request #37725 from
aIbrahiim/fix-python-postcommit-dependency-1
add 9b915fd18f6 Remove logging in tfrecordio.py (#37794)
add b203f53a128 Move FileIO close from RecordWriter to RecordWriterManager
(#37782)
add 6c42cc107f2 [ErrorProne] Enable BadImport ErrorProne check and fix
violations (#37760)
add d10374b755c add py313 dep (#37799)
add d27dc82c568 [IcebergIO] Add ITs for RESTCatalog using BLMS (#35360)
add 5034e40fa0f [Dataflow Streaming] Remove nullness suppression of
StreamingDataflowWorker (#37797)
add d6759cf7dd6 [Dataflow Streaming] Add a pipeline option to skip input
elements that cannot be decoded successfully (#37762)
add 78b22bc11f2 Use p310_ml_test
add eccfdbc213a Merge pull request #37800 from apache/fix-python-ml-3-10
add 084c4da7314 Revert "fix(python): Register all output pcollections of a
transform rather t…" (#37801)
add 6c67a938edd Bump minimatch from 3.1.2 to 3.1.5 in /sdks/typescript
(#37729)
add 57ab2b96113 [Dataflow Java Runner] Add support for sending logs
directly to Cloud Logging (#37662)
add 7d756c2e109 update container version (#37811)
add e6fcdd72ed6 [Java][Debezium] Fix NPE in debeziumRecordInstant for
DELETE events (#37795)
add 8e0736ab304 Loosen GRPC requirements. (#37817)
add 9829d6d3cf9 Merge pull request #37792: [ErrorProne] Fix
AutoValueBoxedValues warnings across the codebase
add edaeae93065 update python container tag (#37812)
add 2ebe33d976a fix non-breaking vulnerabilities (#37826)
add 9f5904b2b59 Support inferring schemas from Python dataclasses (#37728)
add 9d73d769ff0 Only pull license for selected tests and publishing
container (#37827)
add cf536ea06d6 Fix 36181 cloudml benchmarks job (#37803)
add a0674a97db6 [ErrorProne] Fix InvalidParam, InvalidInlineTag,
InvalidBlockTag, and InvalidLink checks (#37773)
add d6bc507d769 Skip intermediate python wheels on pull request trigger
(#37832)
add 630f32ada54 [Drain] Expose drain to dofn processElement and onTimer
(#37825)
add 87d7bba644f docs: Clarify JAVA_HOME setup and initial build
expectations for all OSes (#37415)
add 892fa0a9357 Fix Run in Colab thumbnails blocked by CSP (#37838)
add e497c1e9b43 Partly Revert #37832 (#37837)
add 0705b4376ec apt-get upgrade in container images to install security
fixes. (#37841)
add ab566197fd2 upgrade vllm for vuln (#37843)
add 02d8f56a1e8 [Dataflow Streaming] Remove rolled out Windmill isolated
channels flag (#37844)
add 3b41e8b4320 Remove rolled out Windmill separate heartbeat stream flag
(#37845)
add b92c436ee64 Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds
(#37850)
add d6d2433827d Fix python postcommit 30513 (#37849)
add 5c5c710441c Revert "upgrade vllm for vuln" (#37856)
add 47bab7e7597 [SpannerIO] Add low-latency configuration in Spanner
Change Streams (#37718)
add 0f6c88e0d4b Pin zookeeper in expansion service (#37859)
add b9a7585d7f4 [ErrorProne] Enable StaticAssignmentInConstructor check
(#37786)
add 3b472aaa9d3 [ErrorProne] Enable UnsafeReflectiveConstructionCast check
(#37784)
add 914e425b26d Fix #21317: Replace colons with underscores in window
filenames for Windows compatibility (#37821)
add 85c1b88ce5a [Dataflow Streaming] Create a separate option to control
commit threads with direct path. (#37848)
add 9292e1d8140 [Dataflow Streaming] Prevent commit threads from sharing
commit streams (#37847)
add 487696c9fd1 [Dataflow Logging handler] Change @LazyInit to
AtomicBoolean (#37846)
add e1e2c3ba85c [DebeziumIO] Implement startOffset & offset persistence
for Kafka (#28248) (#37750)
add 4c95230392c [typescript] - fix rest of vulnerabilities (#37852)
add 39c7b46aecb Regenerate beam container image dependencies to include
newer version of grpc. (#37822)
add 4aff88ea91a Revert "[Dataflow Streaming] Prevent commit threads from
sharing commit streams" (#37873)
add 65179691f25 Fix maven archetype dependency for io-components
add 41b513e210c Merge pull request #37871 from Abacn/fix-maven-archtype
add 90c2ab28a26 [Gemini] Fix bad-unpacking pyrefly error (#37828)
add 0fb490f927f [ErrorProne] Enable EmptyCatch Error Prone check and
document ignored exceptions (#37754)
add babf20c99dc Adds validates runner post commit tests for Java streaming
worker on streaming engine (#37872)
add 1007f73c8e4 Update python dev container tag (#37853)
add fa9d19063ba SDF draining in dataflow runner v1 (#37831)
add 8c48120697e Enable error_prone UnnecessaryLongToIntConversion check
(#37783)
add fe29172781f Updated URLs in notebooks: Folders changed from
`/tour-of-beam/` to (#37876)
add 7b33e1cb50b [Java] Improve GroupIntoBatches display data to show
batching parameters (#37865)
add ae6d624c2b6 Add a configuration to wait for session creation (#37625)
add d51177b9cee Add a check to make sure GitHub action workflows are
listed in readme (#37883)
add fee107ada1f Fix vLLM Gemma benchmark by updating transformers version
add d48108d6f83 Merge pull request #37874 from
aIbrahiim/fix-30644-inference-python-benchmark
add 2c99a01f327 Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks
(#37889)
add 6a94e1be935 Bump google.golang.org/api from 0.257.0 to 0.269.0 in /sdks
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 (2eb4c7d3509)
\
N -- N -- N
refs/heads/dependabot/go_modules/sdks/google.golang.org/api-0.269.0
(6a94e1be935)
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:
.../gradle-command-self-hosted-action/action.yml | 2 +-
.github/build.gradle | 6 +
.../IO_Iceberg_Integration_Tests.json | 2 +-
...ValidatesRunner_Dataflow_Streaming_Engine.json} | 0
.github/workflows/README.md | 23 +
..._ValidatesRunner_Dataflow_Streaming_Engine.yml} | 15 +-
.github/workflows/beam_PreCommit_GHA.yml | 2 +-
.github/workflows/beam_PreCommit_GoPortable.yml | 5 +-
.../beam_PreCommit_Java_Examples_Dataflow.yml | 1 +
...eam_PreCommit_Java_Examples_Dataflow_Java21.yml | 1 +
.github/workflows/beam_PreCommit_PythonDocker.yml | 3 +-
.github/workflows/beam_PreCommit_RAT.yml | 2 +-
.github/workflows/beam_PreCommit_Whitespace.yml | 2 +-
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 1 +
.../workflows/beam_Publish_Docker_Snapshots.yml | 6 +-
.github/workflows/build_wheels.yml | 6 +-
.../beam_CloudML_Benchmarks_Dataflow_arguments.txt | 2 +-
...Python_Benchmarks_Dataflow_VLLM_Gemma_Batch.txt | 1 +
CHANGES.md | 1 +
CONTRIBUTING.md | 5 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 22 +-
.../datatokenization/utils/CsvConverters.java | 6 +-
.../examples/complete/game/injector/Injector.java | 6 +-
.../twitterstreamgenerator/TwitterConnection.java | 1 +
.../apache/beam/examples/webapis/ImageRequest.java | 2 +-
.../learn_beam_windowing_by_doing.ipynb | 2 +-
.../interactive-overview/getting-started.ipynb | 6 +-
.../reading-and-writing-data.ipynb | 4 +-
.../clickhouse/conditions/ClickHouseRowsCheck.java | 4 +-
.../org/apache/beam/it/common/TestProperties.java | 6 +-
.../datadog/conditions/DatadogLogEntriesCheck.java | 4 +-
.../java/org/apache/beam/it/gcp/LoadTestBase.java | 4 +-
.../gcp/bigquery/conditions/BigQueryRowsCheck.java | 4 +-
.../gcp/datastream/DatastreamResourceManager.java | 18 +-
.../gcp/pubsub/conditions/PubsubMessagesCheck.java | 4 +-
.../apache/beam/it/gcp/bigquery/BigQueryIOLT.java | 2 +-
.../beam/it/gcp/bigquery/BigQueryStreamingLT.java | 8 +-
.../apache/beam/it/gcp/bigtable/BigTableIOLT.java | 8 +-
.../apache/beam/it/gcp/spanner/SpannerIOLT.java | 2 +-
.../apache/beam/it/gcp/storage/FileBasedIOLT.java | 4 +-
.../java/org/apache/beam/it/kafka/KafkaIOLT.java | 8 +-
.../mongodb/conditions/MongoDBDocumentsCheck.java | 4 +-
.../it/splunk/conditions/SplunkEventsCheck.java | 4 +-
.../beam/it/truthmatchers/ListAccumulator.java | 2 +-
playground/backend/containers/python/Dockerfile | 4 +-
.../cloudbuild/playground_cd_examples.sh | 9 +-
.../org/apache/beam/runners/core/DoFnRunner.java | 3 +-
...TimeBoundedSplittableProcessElementInvoker.java | 26 +-
.../runners/core/PushbackSideInputDoFnRunner.java | 3 +-
.../org/apache/beam/runners/core/ReduceFn.java | 3 +
.../beam/runners/core/ReduceFnContextFactory.java | 38 +-
.../apache/beam/runners/core/ReduceFnRunner.java | 52 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 33 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 36 +-
.../beam/runners/core/StatefulDoFnRunner.java | 3 +-
.../apache/beam/runners/core/WindowMatchers.java | 52 +-
.../beam/runners/core/metrics/BoundedTrieData.java | 2 +-
.../core/metrics/MonitoringInfoMetricName.java | 2 +-
.../runners/core/metrics/SimpleStateRegistry.java | 2 +-
.../core/triggers/AfterWatermarkStateMachine.java | 2 +-
.../runners/core/SplittableParDoProcessFnTest.java | 46 +-
.../apache/beam/runners/direct/DirectRunner.java | 12 +-
.../beam/runners/direct/DirectTimerInternals.java | 4 +-
.../runners/direct/WriteWithShardingFactory.java | 2 +-
.../direct/BoundedReadEvaluatorFactoryTest.java | 11 +-
.../direct/UnboundedReadEvaluatorFactoryTest.java | 44 +-
.../runners/flink/streaming/StreamSources.java | 2 +-
.../wrappers/streaming/DoFnOperator.java | 10 +-
.../wrappers/streaming/DoFnOperator.java | 10 +-
.../runners/flink/streaming/StreamSources.java | 2 +-
.../functions/ImpulseSourceFunctionTest.java | 3 +-
.../flink/FlinkStreamingTranslationContext.java | 2 +-
.../flink/PipelineTranslationModeOptimizer.java | 2 +-
.../flink/adapter/BeamFlinkDataStreamAdapter.java | 3 +-
.../runners/flink/metrics/MetricsAccumulator.java | 1 +
.../functions/FlinkSideInputReader.java | 2 +-
.../translation/utils/LookupPipelineVisitor.java | 2 +-
.../wrappers/streaming/DoFnOperator.java | 10 +-
.../functions/ImpulseSourceFunctionTest.java | 3 +-
runners/google-cloud-dataflow-java/build.gradle | 17 +-
.../dataflow/DataflowPipelineTranslator.java | 90 +-
.../runners/dataflow/GroupIntoBatchesOverride.java | 12 +
.../options/DataflowStreamingPipelineOptions.java | 23 +-
.../options/DataflowWorkerLoggingOptions.java | 74 +
.../beam/runners/dataflow/util/PackageUtil.java | 10 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 138 ++
.../google-cloud-dataflow-java/worker/build.gradle | 7 +-
.../dataflow/worker/BatchDataflowWorker.java | 4 +-
.../dataflow/worker/BatchModeExecutionContext.java | 6 +-
.../worker/DataflowElementExecutionTracker.java | 8 +-
.../dataflow/worker/DataflowExecutionContext.java | 4 +-
.../dataflow/worker/GroupAlsoByWindowFnRunner.java | 6 +-
.../dataflow/worker/GroupAlsoByWindowsParDoFn.java | 2 +
.../MetricsToPerStepNamespaceMetricsConverter.java | 11 +-
.../beam/runners/dataflow/worker/PubsubReader.java | 42 +-
.../dataflow/worker/StreamingDataflowWorker.java | 82 +-
.../worker/StreamingStepMetricsContainer.java | 5 +-
.../dataflow/worker/UngroupedWindmillReader.java | 41 +-
.../dataflow/worker/WindmillKeyedWorkItem.java | 105 +-
.../worker/WindmillReaderIteratorBase.java | 59 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 64 +-
.../dataflow/worker/WindowingWindmillReader.java | 55 +-
.../runners/dataflow/worker/WorkUnitClient.java | 2 +-
.../dataflow/worker/WorkerCustomSources.java | 8 +-
.../dataflow/worker/counters/CounterFactory.java | 2 +-
.../logging/DataflowWorkerLoggingHandler.java | 781 ++++++--
.../logging/DataflowWorkerLoggingInitializer.java | 180 +-
.../JulHandlerPrintStreamAdapterFactory.java | 11 +-
.../StreamingEngineComputationConfigFetcher.java | 2 +-
.../runners/dataflow/worker/util/JfrInterop.java | 2 +
.../dataflow/worker/util/MemoryMonitor.java | 2 +-
.../util/ThreadLocalByteStringOutputStream.java | 2 +-
.../common/worker/BatchingShuffleEntryReader.java | 2 +-
.../common/worker/CachingShuffleBatchReader.java | 4 +-
.../util/common/worker/WorkProgressUpdater.java | 10 +-
.../windmill/client/AbstractWindmillStream.java | 47 +-
.../client/ResettableThrowingStreamObserver.java | 17 +-
.../windmill/client/grpc/GrpcDispatcherClient.java | 48 +-
.../windmill/client/grpc/GrpcGetDataStream.java | 14 +-
.../windmill/client/grpc/GrpcWindmillServer.java | 3 +-
.../grpc/stubs/WindmillStubFactoryFactory.java | 2 +-
.../grpc/stubs/WindmillStubFactoryFactoryImpl.java | 19 +-
.../dataflow/worker/windmill/state/RangeCoder.java | 4 +-
.../windmill/state/WindmillTagEncodingV1.java | 7 +-
.../windmill/state/WindmillTagEncodingV2.java | 6 +-
.../work/processing/StreamingCommitFinalizer.java | 2 +
.../work/processing/StreamingWorkScheduler.java | 21 +-
.../processing/failures/WorkFailureProcessor.java | 118 +-
.../work/refresh/StreamPoolHeartbeatSender.java | 27 -
.../worker/StreamingDataflowWorkerTest.java | 135 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 95 +-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 106 +-
.../worker/WindmillReaderIteratorBaseTest.java | 42 +-
.../logging/DataflowWorkerLoggingHandlerTest.java | 504 +++++-
.../DataflowWorkerLoggingInitializerTest.java | 111 +-
.../JulHandlerPrintStreamAdapterFactoryTest.java | 4 +-
.../worker/status/WorkerStatusPagesTest.java | 9 +-
.../config/FixedGlobalConfigHandleTest.java | 5 +-
.../StreamingGlobalConfigHandleImplTest.java | 17 +-
.../FanOutStreamingEngineWorkerHarnessTest.java | 3 -
.../harness/SingleSourceWorkerHarnessTest.java | 15 +-
.../client/grpc/GrpcDispatcherClientTest.java | 141 --
.../windmill/state/WindmillTagEncodingV2Test.java | 8 +-
.../testing/FakeWindmillStubFactoryFactory.java | 2 +-
.../failures/WorkFailureProcessorTest.java | 22 +-
.../work/refresh/ActiveWorkRefresherTest.java | 8 +-
.../refresh/StreamPoolHeartbeatSenderTest.java | 84 -
.../worker/windmill/src/main/proto/windmill.proto | 8 +-
.../artifact/ArtifactStagingService.java | 3 +-
.../control/ProcessBundleDescriptors.java | 2 +-
...renceCountingExecutableStageContextFactory.java | 4 +-
.../environment/EmbeddedEnvironmentFactory.java | 2 +
.../control/DefaultJobBundleFactoryTest.java | 9 +-
.../runners/fnexecution/wire/CommonCoderTest.java | 2 +-
.../beam/runners/jobsubmission/JobInvocation.java | 13 +-
.../java/org/apache/beam/runners/jet/Utils.java | 2 +-
.../apache/beam/runners/prism/PrismExecutor.java | 6 +-
.../apache/beam/runners/prism/PrismLocator.java | 2 +-
.../beam/runners/prism/PrismPipelineResult.java | 2 +-
.../samza/metrics/SamzaTransformMetrics.java | 3 +-
.../samza/runtime/ClassicBundleManager.java | 9 +-
.../runners/samza/translation/ConfigBuilder.java | 2 +-
.../translation/ParDoBoundMultiTranslator.java | 4 +-
.../translation/SplittableParDoTranslators.java | 2 +-
.../TestSamzaRunnerWithTransformMetrics.java | 4 +-
.../metrics/TestSamzaTransformMetricsRegistry.java | 4 +-
.../translation/helpers/EncoderHelpers.java | 77 +-
.../aggregators/metrics/sink/InMemoryMetrics.java | 26 +-
.../spark/translation/EvaluationContext.java | 2 +-
.../spark/translation/GroupCombineFunctions.java | 2 +-
.../spark/translation/SparkInputDataProcessor.java | 4 +-
.../runners/spark/util/CachedSideInputReader.java | 10 +-
.../aggregators/metrics/sink/InMemoryMetrics.java | 26 +-
.../coders/SparkRunnerKryoRegistratorTest.java | 3 +-
.../twister2/Twister2TranslationContext.java | 2 +-
sdks/go.mod | 44 +-
sdks/go.sum | 929 +---------
sdks/go/pkg/beam/io/xlang/debeziumio/debezium.go | 40 +
sdks/java/core/build.gradle | 2 +-
.../java/org/apache/beam/sdk/PipelineResult.java | 4 +-
.../apache/beam/sdk/coders/BigDecimalCoder.java | 4 +-
.../sdk/coders/CannotProvideCoderException.java | 2 +-
.../org/apache/beam/sdk/coders/DelegateCoder.java | 2 +-
.../beam/sdk/coders/StringDelegateCoder.java | 2 +-
.../sdk/fn/channel/AddHarnessIdInterceptor.java | 4 +-
.../sdk/fn/data/BeamFnDataOutboundAggregator.java | 2 +
.../server/GrpcContextHeaderAccessorProvider.java | 5 +-
.../org/apache/beam/sdk/fn/test/TestStreams.java | 20 +-
.../org/apache/beam/sdk/io/CompressedSource.java | 20 +-
.../apache/beam/sdk/io/DefaultFilenamePolicy.java | 11 +-
.../java/org/apache/beam/sdk/io/FileBasedSink.java | 24 +-
.../java/org/apache/beam/sdk/io/FileSystem.java | 4 +-
.../java/org/apache/beam/sdk/io/FileSystems.java | 4 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 4 +-
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 10 +-
.../main/java/org/apache/beam/sdk/io/TextIO.java | 16 +-
.../java/org/apache/beam/sdk/io/TextSource.java | 6 +-
.../apache/beam/sdk/metrics/BoundedTrieResult.java | 2 +-
.../beam/sdk/metrics/MetricsEnvironment.java | 11 +-
.../apache/beam/sdk/metrics/StringSetResult.java | 2 +-
.../org/apache/beam/sdk/options/ValueProvider.java | 2 +
.../GenerateSequenceSchemaTransformProvider.java | 12 +-
.../apache/beam/sdk/runners/AppliedPTransform.java | 2 +-
.../apache/beam/sdk/schemas/AutoValueSchema.java | 10 +-
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 10 +-
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 10 +-
.../java/org/apache/beam/sdk/schemas/Schema.java | 10 +-
.../schemas/logicaltypes/UnknownLogicalType.java | 2 +-
.../apache/beam/sdk/schemas/transforms/Group.java | 4 +-
.../beam/sdk/transforms/ApproximateQuantiles.java | 5 +-
.../beam/sdk/transforms/ApproximateUnique.java | 2 +
.../java/org/apache/beam/sdk/transforms/DoFn.java | 7 +-
.../beam/sdk/transforms/DoFnOutputReceivers.java | 3 +-
.../org/apache/beam/sdk/transforms/DoFnTester.java | 27 +-
.../org/apache/beam/sdk/transforms/Flatten.java | 2 +-
.../beam/sdk/transforms/GroupIntoBatches.java | 24 +-
.../org/apache/beam/sdk/transforms/JsonToRow.java | 6 +-
.../org/apache/beam/sdk/transforms/MapKeys.java | 1 -
.../apache/beam/sdk/transforms/Redistribute.java | 6 +-
.../beam/sdk/transforms/display/DisplayData.java | 2 +
.../reflect/ByteBuddyDoFnInvokerFactory.java | 15 +-
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 15 +
.../beam/sdk/transforms/reflect/DoFnSignature.java | 28 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 14 +-
.../beam/sdk/transforms/windowing/AfterAll.java | 5 +
.../beam/sdk/transforms/windowing/AfterEach.java | 7 +-
.../beam/sdk/transforms/windowing/AfterFirst.java | 5 +
.../beam/sdk/transforms/windowing/AfterPane.java | 5 +
.../transforms/windowing/AfterProcessingTime.java | 5 +
.../windowing/AfterSynchronizedProcessingTime.java | 5 +
.../sdk/transforms/windowing/AfterWatermark.java | 14 +-
.../sdk/transforms/windowing/DefaultTrigger.java | 5 +
.../beam/sdk/transforms/windowing/Never.java | 5 +
.../sdk/transforms/windowing/OrFinallyTrigger.java | 5 +
.../beam/sdk/transforms/windowing/PaneInfo.java | 6 +-
.../beam/sdk/transforms/windowing/Repeatedly.java | 5 +
.../sdk/transforms/windowing/ReshuffleTrigger.java | 5 +
.../beam/sdk/transforms/windowing/Trigger.java | 3 +
.../windowing/TriggerVisitor.java} | 33 +-
.../org/apache/beam/sdk/util/FluentBackoff.java | 2 +-
.../org/apache/beam/sdk/util/InstanceBuilder.java | 24 +-
.../java/org/apache/beam/sdk/util/MoreFutures.java | 4 +
.../org/apache/beam/sdk/util/MutationDetector.java | 2 +-
.../beam/sdk/util/RowStringInterpolator.java | 8 +-
.../util/construction/PTransformReplacements.java | 6 +-
.../sdk/util/construction/ParDoTranslation.java | 2 +-
.../construction/SplittableParDoNaiveBounded.java | 5 +
.../sdk/util/construction/TransformUpgrader.java | 3 +-
.../sdk/util/construction/TriggerTranslation.java | 165 +-
.../sdk/util/construction/UnknownCoderWrapper.java | 2 +-
.../construction/resources/PipelineResources.java | 9 +-
.../beam/sdk/values/ValueInSingleWindow.java | 20 +-
.../org/apache/beam/sdk/values/WindowedValues.java | 4 +-
.../test/java/org/apache/beam/sdk/TestUtils.java | 10 +-
.../beam/sdk/coders/BigDecimalCoderTest.java | 1 -
.../org/apache/beam/sdk/io/TextIOReadTest.java | 8 +-
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 155 +-
.../beam/sdk/schemas/AutoValueSchemaTest.java | 4 +-
.../beam/sdk/schemas/JsonSchemaConversionTest.java | 15 +-
.../apache/beam/sdk/schemas/SchemaCoderTest.java | 6 +-
.../beam/sdk/schemas/transforms/SelectTest.java | 8 +-
.../TypedSchemaTransformProviderTest.java | 4 +-
.../org/apache/beam/sdk/transforms/CreateTest.java | 7 +-
.../apache/beam/sdk/transforms/FlattenTest.java | 12 +-
.../beam/sdk/transforms/ParDoSchemaTest.java | 8 +-
.../org/apache/beam/sdk/transforms/ToJsonTest.java | 6 +-
.../errorhandling/BadRecordRouterTest.java | 29 +-
.../sdk/transforms/reflect/DoFnSignaturesTest.java | 34 +-
.../GrowableOffsetRangeTrackerTest.java | 16 +-
.../beam/sdk/transforms/windowing/StubTrigger.java | 5 +
.../beam/sdk/transforms/windowing/TriggerTest.java | 10 +
.../beam/sdk/util/SerializableUtilsTest.java | 3 +-
.../UnboundedScheduledExecutorServiceTest.java | 152 +-
.../sdk/expansion/service/ExpansionService.java | 2 +-
.../sdk/expansion/service/TransformProvider.java | 2 +-
.../expansion/service/ExpansionServiceTest.java | 2 +-
.../extensions/avro/schemas/utils/AvroUtils.java | 64 +-
.../avro/schemas/utils/AvroUtilsTest.java | 131 +-
.../euphoria/core/annotation/operator/Basic.java | 4 +-
.../euphoria/core/annotation/operator/Derived.java | 4 +-
.../core/annotation/operator/Recommended.java | 8 +-
.../extensions/euphoria/core/client/lib/Split.java | 4 +-
.../core/client/operator/AssignEventTime.java | 9 +-
.../euphoria/core/client/operator/FullJoin.java | 3 +-
.../euphoria/core/client/operator/ReduceByKey.java | 6 +-
.../core/client/operator/ReduceWindow.java | 2 +-
.../euphoria/core/client/operator/RightJoin.java | 3 +-
.../euphoria/core/client/util/SumsTest.java | 2 +-
.../SingleJvmAccumulatorProviderTest.java | 4 +-
.../collector/SingleValueCollectorTest.java | 4 +-
.../sdk/extensions/gcp/util/CustomHttpErrors.java | 2 +-
.../sdk/extensions/gcp/util/GceMetadataUtil.java | 17 +-
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 2 +-
.../extensions/gcp/util/HttpCallCustomError.java | 2 +-
.../sdk/extensions/gcp/util/HttpCallMatcher.java | 2 +-
.../LatencyRecordingHttpRequestInitializer.java | 2 +-
.../gcp/util/RetryHttpRequestInitializer.java | 12 +-
.../kafka/factories/FileAwareFactoryFn.java | 8 +-
.../beam/sdk/extensions/ml/DLPDeidentifyText.java | 53 +-
.../beam/sdk/extensions/ml/DLPInspectText.java | 40 +-
.../beam/sdk/extensions/ml/DLPReidentifyText.java | 52 +-
.../ml/RecommendationAICreateCatalogItem.java | 18 +-
.../ml/RecommendationAIImportCatalogItems.java | 33 +-
.../ml/RecommendationAIImportUserEvents.java | 41 +-
.../sdk/extensions/ml/RecommendationAIPredict.java | 32 +-
.../ml/RecommendationAIWriteUserEvent.java | 24 +-
.../ordered/ContiguousSequenceRange.java | 6 +-
.../ordered/OrderedEventProcessorResult.java | 14 +-
.../ordered/OrderedProcessingHandler.java | 4 +-
.../ordered/OrderedProcessingStatus.java | 28 +-
.../beam/sdk/extensions/ordered/ProcessorDoFn.java | 2 +-
.../ordered/OrderedEventProcessorTestBase.java | 2 +-
.../extensions/sketching/ApproximateDistinct.java | 5 +-
.../provider/bigquery/BigQueryIOPushDownIT.java | 2 +-
.../extensions/sql/impl/parser/SqlAlterTable.java | 2 +-
.../sql/impl/parser/SqlCreateExternalTable.java | 2 +-
.../sql/meta/catalog/CatalogManager.java | 4 +-
.../apache/beam/sdk/extensions/sql/TestUtils.java | 2 +-
.../beam/sdk/extensions/timeseries/FillGaps.java | 8 +-
.../zetasketch/ApproximateCountDistinct.java | 8 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 61 +-
.../SplittablePairWithRestrictionDoFnRunner.java | 2 +
...littableSplitAndSizeRestrictionsDoFnRunner.java | 4 +-
...ittableTruncateSizedRestrictionsDoFnRunner.java | 2 +
.../fn/harness/control/ProcessBundleHandler.java | 2 +
.../harness/data/PTransformFunctionRegistry.java | 4 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 2 +
.../apache/beam/fn/harness/logging/QuotaEvent.java | 16 +-
.../fn/harness/state/FnApiTimerBundleTracker.java | 2 +
.../sdk/io/aws2/common/AsyncBatchWriteHandler.java | 4 +-
.../io/aws2/kinesis/EFOShardSubscribersPool.java | 23 +-
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 4 +-
.../beam/sdk/io/aws2/kinesis/KinesisRecord.java | 8 +-
.../io/aws2/kinesis/RateLimitPolicyFactory.java | 6 +-
.../org/apache/beam/sdk/io/aws2/sqs/SqsIO.java | 7 +-
.../io/aws2/common/AsyncBatchWriteHandlerTest.java | 1 +
.../sdk/io/aws2/dynamodb/testing/DynamoDBIOIT.java | 2 +-
.../sdk/io/aws2/kinesis/KinesisIOWriteTest.java | 10 +-
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 23 +-
.../apache/beam/sdk/io/cassandra/RingRange.java | 4 +-
.../org/apache/beam/sdk/io/cdap/ConfigWrapper.java | 2 +-
.../io/cdap/PluginConfigInstantiationUtils.java | 4 +-
.../java/org/apache/beam/sdk/io/cdap/CdapIOIT.java | 2 +-
.../apache/beam/sdk/io/cdap/TestRowDBWritable.java | 6 +-
.../beam/sdk/io/common/NetworkTestHelper.java | 2 +-
.../beam/sdk/io/common/SchemaAwareJavaBeans.java | 36 +-
.../org/apache/beam/sdk/io/common/TestRow.java | 10 +-
.../io/contextualtextio/ContextualTextIOTest.java | 12 +-
.../beam/sdk/io/datadog/DatadogEventPublisher.java | 10 +-
.../org/apache/beam/io/debezium/DebeziumIO.java | 76 +
.../DebeziumReadSchemaTransformProvider.java | 4 +-
.../io/debezium/DebeziumTransformRegistrar.java | 38 +
.../beam/io/debezium/FileSystemOffsetRetainer.java | 166 ++
.../apache/beam/io/debezium/KafkaConnectUtils.java | 27 +-
.../beam/io/debezium/KafkaSourceConsumerFn.java | 26 +-
.../apache/beam/io/debezium/OffsetRetainer.java | 69 +
.../apache/beam/io/debezium/DebeziumIOTest.java | 152 ++
.../io/debezium/FileSystemOffsetRetainerTest.java | 131 ++
.../beam/io/debezium/KafkaConnectSchemaTest.java | 41 +-
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 14 +-
sdks/java/io/expansion-service/build.gradle | 3 +
.../FileReadSchemaTransformFormatProviderTest.java | 2 +-
.../AvroGenericRecordToStorageApiProto.java | 2 +-
.../io/gcp/bigquery/BeamRowToStorageApiProto.java | 12 +-
.../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 13 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 60 +-
.../sdk/io/gcp/bigquery/BigQueryIOTranslation.java | 40 +-
.../sdk/io/gcp/bigquery/BigQuerySinkMetrics.java | 15 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 25 +-
.../io/gcp/bigquery/RowMutationInformation.java | 16 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 4 +-
.../bigquery/StorageApiWritesShardedRecords.java | 7 +-
.../io/gcp/bigquery/StreamingInsertsMetrics.java | 2 +-
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 51 +-
.../beam/sdk/io/gcp/bigquery/WritePartition.java | 2 +-
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 2 +-
.../gcp/bigtable/changestreams/dao/DaoFactory.java | 1 +
.../changestreams/dao/MetadataTableAdminDao.java | 2 +-
.../changestreams/dao/MetadataTableDao.java | 8 +-
.../beam/sdk/io/gcp/firestore/FirestoreDoFn.java | 8 +-
.../apache/beam/sdk/io/gcp/firestore/RpcQos.java | 10 +-
.../beam/sdk/io/gcp/firestore/RpcQosImpl.java | 5 +-
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 3 +-
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java | 8 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 2 +-
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 1 +
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 1 +
.../beam/sdk/io/gcp/spanner/OrderedCode.java | 2 +-
.../beam/sdk/io/gcp/spanner/ReadSpannerSchema.java | 2 +-
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 14 +
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 25 +
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 78 +-
.../changestreams/ChangeStreamsConstants.java | 9 +
.../changestreams/action/ActionFactory.java | 12 +-
.../action/HeartbeatRecordAction.java | 14 +-
.../action/QueryChangeStreamAction.java | 25 +-
.../spanner/changestreams/dofn/InitializeDoFn.java | 12 +-
.../dofn/ReadChangeStreamPartitionDoFn.java | 18 +-
.../beam/sdk/io/gcp/testing/BigqueryMatcher.java | 4 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 17 +-
.../AvroGenericRecordToStorageApiProtoTest.java | 61 +-
.../gcp/bigquery/BeamRowToStorageApiProtoTest.java | 71 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 9 +-
.../bigquery/TableRowToStorageApiProtoTest.java | 149 +-
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 16 +-
.../io/gcp/bigtable/BigtableSharedClientTest.java | 8 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 2 +-
.../estimator/NullSizeEstimatorTest.java | 6 +-
...artitionQueryResponseToRunQueryRequestTest.java | 2 +-
.../sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 4 +-
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 8 +-
.../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 5 +
.../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 5 +
.../action/HeartbeatRecordActionTest.java | 149 +-
.../action/QueryChangeStreamActionTest.java | 114 +-
.../changestreams/dofn/InitializeDoFnTest.java | 3 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 19 +-
.../changestreams/it/IntegrationTestEnv.java | 5 +
.../restriction/TimestampRangeTrackerTest.java | 7 +-
.../spanner/changestreams/util/TestJsonMapper.java | 8 +-
.../sdk/io/hadoop/format/TestRowDBWritable.java | 6 +-
.../beam/sdk/io/hbase/HBaseRowMutationsCoder.java | 2 +-
.../org/apache/beam/sdk/io/hbase/HBaseIOIT.java | 2 +-
.../sdk/io/hcatalog/HiveDatabaseTestHelper.java | 17 +-
sdks/java/io/iceberg/build.gradle | 1 +
.../apache/beam/sdk/io/iceberg/FilterUtils.java | 1 +
.../apache/beam/sdk/io/iceberg/RecordWriter.java | 25 +-
.../beam/sdk/io/iceberg/RecordWriterManager.java | 64 +-
.../sdk/io/iceberg/RecordWriterManagerTest.java | 102 +-
.../io/iceberg/catalog/IcebergCatalogBaseIT.java | 28 +-
.../sdk/io/iceberg/catalog/RESTCatalogBLMSIT.java | 75 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 4 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 4 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 10 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 6 +-
.../KafkaIOReadImplementationCompatibility.java | 8 +-
.../org/apache/beam/sdk/io/kafka/KafkaMetrics.java | 2 +-
.../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 4 +-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 117 +-
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 8 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 4 +-
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 6 +-
.../org/apache/beam/sdk/io/kafka/KafkaDlqTest.java | 14 +-
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 12 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 2 +-
...KafkaIOReadImplementationCompatibilityTest.java | 16 +-
.../KafkaUnboundedReaderIdlePartitionTest.java | 273 +++
.../KafkaWriteSchemaTransformProviderTest.java | 22 +-
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 60 +-
.../apache/beam/sdk/io/parquet/ParquetIOTest.java | 92 +
.../org/apache/beam/sdk/io/pulsar/PulsarIOIT.java | 2 +-
.../beam/sdk/io/rabbitmq/ExchangeTestPlan.java | 2 +-
.../org/apache/beam/io/requestresponse/Call.java | 55 +-
.../apache/beam/io/requestresponse/Monitoring.java | 170 +-
.../apache/beam/io/requestresponse/Repeater.java | 1 +
.../beam/io/requestresponse/SetupTeardown.java | 2 +-
.../EchoGRPCCallerWithSetupTeardown.java | 1 +
.../io/requestresponse/RequestResponseIOTest.java | 8 +-
.../beam/sdk/io/singlestore/SingleStoreIO.java | 4 +-
.../apache/beam/sdk/io/singlestore/TestHelper.java | 2 +-
.../sdk/io/snowflake/data/SnowflakeDataType.java | 51 +-
.../io/snowflake/test/FakeSnowflakeDatabase.java | 10 +-
.../org/apache/beam/sdk/io/solace/data/Solace.java | 4 +-
.../beam/sdk/io/sparkreceiver/HasOffset.java | 8 +-
.../beam/sdk/io/sparkreceiver/ReceiverBuilder.java | 4 +-
.../sdk/io/sparkreceiver/SparkReceiverIOIT.java | 5 +-
.../beam/sdk/io/splunk/HttpEventPublisher.java | 8 +-
.../beam/sdk/io/synthetic/BundleSplitter.java | 2 +-
.../java/org/apache/beam/sdk/io/xml/XmlIO.java | 14 +-
.../testing/TestSchemaTransformProvider.java | 6 +-
.../src/main/resources/archetype-resources/pom.xml | 6 +
.../src/main/resources/archetype-resources/pom.xml | 6 +
.../org/apache/beam/sdk/loadtests/LoadTest.java | 2 +-
.../apache/beam/sdk/nexmark/NexmarkQueryName.java | 4 +-
.../beam/sdk/nexmark/queries/Query4Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query6Model.java | 2 +-
sdks/python/apache_beam/coders/coder_impl.py | 6 +-
.../inference/pytorch_language_modeling.py | 3 +-
.../examples/inference/vllm_gemma_batch.py | 1 -
sdks/python/apache_beam/io/debezium.py | 44 +-
sdks/python/apache_beam/io/tfrecordio.py | 5 -
.../ml/inference/vertex_ai_inference_it_test.py | 5 +-
.../ml/inference/vllm_tests_requirements.txt | 3 +-
.../ml/rag/embeddings/vertex_ai_test.py | 26 +-
.../{vertex_ai_test.py => vertex_ai_it_test.py} | 14 +-
sdks/python/apache_beam/pipeline.py | 5 +-
sdks/python/apache_beam/pipeline_test.py | 7 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../runners/interactive/interactive_runner.py | 6 +
.../runners/interactive/interactive_runner_test.py | 20 +
.../testing/benchmarks/cloudml/requirements.txt | 12 +-
.../typehints/native_type_compatibility.py | 5 +
sdks/python/apache_beam/typehints/row_type.py | 47 +-
sdks/python/apache_beam/typehints/row_type_test.py | 90 +
sdks/python/apache_beam/typehints/schemas.py | 3 +-
sdks/python/apache_beam/typehints/schemas_test.py | 61 +
sdks/python/apache_beam/yaml/yaml_ml.py | 7 +-
sdks/python/container/Dockerfile | 1 +
.../container/base_image_requirements_manual.txt | 4 +
.../container/license_scripts/dep_urls_py.yaml | 4 +-
.../container/license_scripts/pull_licenses_py.py | 2 +-
.../container/ml/py310/base_image_requirements.txt | 69 +-
.../container/ml/py310/gpu_image_requirements.txt | 74 +-
.../container/ml/py311/base_image_requirements.txt | 78 +-
.../container/ml/py311/gpu_image_requirements.txt | 81 +-
.../container/ml/py312/base_image_requirements.txt | 75 +-
.../container/ml/py312/gpu_image_requirements.txt | 79 +-
.../container/ml/py313/base_image_requirements.txt | 70 +-
.../container/py310/base_image_requirements.txt | 53 +-
.../container/py311/base_image_requirements.txt | 62 +-
.../container/py312/base_image_requirements.txt | 59 +-
.../container/py313/base_image_requirements.txt | 54 +-
sdks/python/pyproject.toml | 3 +
sdks/python/pyrefly.toml | 3 +-
sdks/python/setup.py | 33 +-
sdks/python/test-suites/tox/py310/build.gradle | 50 +-
sdks/python/tox.ini | 8 +-
sdks/typescript/package-lock.json | 1877 +++++++++++---------
sdks/typescript/package.json | 10 +-
sdks/typescript/test/primitives_test.ts | 12 +-
.../www/site/layouts/shortcodes/button-colab.html | 2 +-
website/www/site/static/images/colab/icon32.png | Bin 0 -> 1418 bytes
524 files changed, 8800 insertions(+), 5264 deletions(-)
copy
.github/trigger_files/{beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json
=> beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_Engine.json} (100%)
copy
.github/workflows/{beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.yml
=> beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming_Engine.yml} (90%)
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDispatcherClientTest.java
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/{testing/UsesStatefulParDo.java
=> transforms/windowing/TriggerVisitor.java} (56%)
create mode 100644
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/FileSystemOffsetRetainer.java
create mode 100644
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/OffsetRetainer.java
create mode 100644
sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/FileSystemOffsetRetainerTest.java
create mode 100644
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/RESTCatalogBLMSIT.java
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReaderIdlePartitionTest.java
rename sdks/python/apache_beam/ml/transforms/embeddings/{vertex_ai_test.py =>
vertex_ai_it_test.py} (98%)
create mode 100644 sdks/python/apache_beam/typehints/row_type_test.py
create mode 100644 website/www/site/static/images/colab/icon32.png
