This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch users/damccorm/prismByDefault
in repository https://gitbox.apache.org/repos/asf/beam.git
from cb97e70dbcc Dont wait on tmpfile being destroyed
add f56d0fabd35 Stale claner implementation (#35439)
add 4d58e6dbdbd Cloudpickle configurable (#35422)
add f9b7c749c02 Revert "Parse v2 record. (#35408)" (#35469)
add 42f232be981 Remove stdout prints from HistogramData (#35458)
add 2ad4eeab657 Drop junit-dep dependency by removing system-rules usage
(#35464)
add 2e313a9f133 added waitForConditionAndForceCancel (#35465)
add dd9552cce05 fixed the beam yaml create issue by creating the full dict
(#35438)
add 431cb560d7d Fix logic in lookup_blob to correctly return blob in
bucket (#35475)
add 755082a49ba Fix flakiness in fuzzy tests and support TimestampTypes in
PeriodicImpulse. (#35470)
add 510d842170e [1/3] sdks/python: enrich data with Milvus Search [Vector,
Keyword, Hybrid] (#35216)
add 4dba4b333d8 Decrease load (#35482)
add f4f0e9a0e1a Skip test if no python interpreter. (#35486)
add dc2a9943e85 [yaml]: fix filter sql issue (#35490)
add 27a653f2d3e Fix PostCommit Python Xlang IO Direct (#35491)
add ffb359c9235 add dependency (#35480)
add ec5e85fdc8e Actually publish distroless containers when releasing
(#35485)
add 38caad753d8 Bump github.com/nats-io/nats-server/v2 from 2.11.4 to
2.11.5 in /sdks (#35454)
add be7fe22110e Bump github.com/docker/docker in /sdks (#35427)
add 4d9b4363ae6 Consider windows with bands outside of [Min, Max]
equivalent (#35460)
add 3644d189caa Merge branch 'master' of https://github.com/apache/beam
into users/damccorm/prismByDefault
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Python_Xlang_IO_Direct.yml | 2 +-
.../go_GBK_Flink_Batch_10b.txt | 2 +-
.test-infra/tools/build.gradle | 5 +
.test-infra/tools/stale_cleaner.py | 45 +-
.test-infra/tools/test_stale_cleaner.py | 4 +-
CHANGES.md | 3 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 19 +-
.../apache/beam/it/common/PipelineLauncher.java | 11 +
.../apache/beam/it/common/PipelineOperator.java | 14 +
.../beam/it/common/PipelineOperatorTest.java | 34 +
.../it/gcp/dataflow/AbstractPipelineLauncher.java | 14 +
.../beam/it/gcp/dataflow/DirectRunnerClient.java | 6 +
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
sdks/java/container/build.gradle | 1 +
.../container/license_scripts/dep_urls_java.yaml | 6 +-
sdks/java/core/build.gradle | 2 -
.../org/apache/beam/sdk/util/HistogramData.java | 5 -
.../apache/beam/sdk/fn/JvmInitializersTest.java | 30 +-
.../changestreams/dao/ChangeStreamResultSet.java | 20 -
.../mapper/ChangeStreamRecordMapper.java | 213 +--
.../changestreams/model/DataChangeRecord.java | 2 +-
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 1 +
.../mapper/ChangeStreamRecordMapperTest.java | 109 --
.../changestreams/util/TestProtoMapper.java | 257 ----
.../apache_beam/coders/coders_test_common.py | 9 +-
.../internal/cloudpickle/cloudpickle.py | 95 +-
.../apache_beam/internal/cloudpickle_pickler.py | 8 +-
sdks/python/apache_beam/io/gcp/gcsio_test.py | 3 +-
.../ml/rag/enrichment/bigquery_vector_search.py | 4 +-
.../apache_beam/ml/rag/enrichment/milvus_search.py | 599 +++++++++
.../ml/rag/enrichment/milvus_search_it_test.py | 1371 ++++++++++++++++++++
.../ml/rag/enrichment/milvus_search_test.py | 343 +++++
sdks/python/apache_beam/ml/rag/types.py | 14 +-
.../transforms/managed_iceberg_it_test.py | 4 +-
.../apache_beam/transforms/periodicsequence.py | 72 +-
.../transforms/periodicsequence_test.py | 74 +-
sdks/python/apache_beam/yaml/tests/create.yaml | 19 +-
sdks/python/apache_beam/yaml/tests/filter.yaml | 23 +
sdks/python/apache_beam/yaml/yaml_mapping.py | 2 +-
sdks/python/apache_beam/yaml/yaml_provider.py | 36 +-
sdks/python/container/build.gradle | 1 +
sdks/python/container/distroless/build.gradle | 8 +-
.../container/license_scripts/dep_urls_py.yaml | 2 +
.../container/py310/base_image_requirements.txt | 31 +-
.../container/py311/base_image_requirements.txt | 33 +-
.../container/py312/base_image_requirements.txt | 31 +-
.../container/py39/base_image_requirements.txt | 31 +-
sdks/python/container/run_generate_requirements.sh | 4 +-
sdks/python/setup.py | 4 +-
50 files changed, 2835 insertions(+), 803 deletions(-)
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/util/TestProtoMapper.java
create mode 100644 sdks/python/apache_beam/ml/rag/enrichment/milvus_search.py
create mode 100644
sdks/python/apache_beam/ml/rag/enrichment/milvus_search_it_test.py
create mode 100644
sdks/python/apache_beam/ml/rag/enrichment/milvus_search_test.py
