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 e26735d69f0 connect err (#28170)
add 505f9421387 Fix flaky test StreamingDataflowWorkerTest (#28173)
add 45ea758b615 [yaml] yaml_transform.py unit tests python - PR 3/3
(#27356)
add 48da8720a42 Add MLTransform IT test (#27620)
add 252c713e9f8 Shell out to model handlers to collect byte sizes (#28182)
add 2d5aced0126 [prism] Add a debugz page to standalone web ui. (#28183)
add 39bafd2ee1d Bump github.com/proullon/ramsql from 0.0.1 to 0.1.2 in
/sdks (#28180)
add 687ed79f1f7 [#28187][prism] worker shutdown, cleanup, log fail, port
spec, grpc recv size (#28184)
add 33aa34f819c Fix a bug that maxConnections is Short in config but read
back as Integer (#28174)
add b4bec8c9b06 add to style guide
add a0d7e53240b Merge pull request #28148: Add PTransform Design Doc to
website
add 6e00a27edcc Bump github.com/tetratelabs/wazero from 1.4.0 to 1.5.0 in
/sdks (#28154)
add f0c0685dbe0 Update ttypescript version. (#28133)
add c8f3b51cec1 Fix ConcurrentModificationException in OutputSampler
add 1eda6dbfcf8 Merge pull request #28150: Fix
ConcurrentModificationException in OutputSampler
add c416f4f6f28 Add per key inference integration test (#28026)
No new revisions were added by this update.
Summary of changes:
.../dataflow/worker/util/BoundedQueueExecutor.java | 24 +-
.../worker/StreamingDataflowWorkerTest.java | 49 +-
sdks/go.mod | 8 +-
sdks/go.sum | 27 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 10 +
.../beam/runners/prism/internal/jobservices/job.go | 1 +
.../runners/prism/internal/jobservices/server.go | 3 +-
.../pkg/beam/runners/prism/internal/preprocess.go | 2 +-
.../runners/prism/internal/web/assets/style.css | 20 +
.../pkg/beam/runners/prism/internal/web/debugz.go | 150 ++++
.../prism/internal/web/{index.html => debugz.html} | 15 +-
.../pkg/beam/runners/prism/internal/web/index.html | 3 +
sdks/go/pkg/beam/runners/prism/internal/web/web.go | 17 +-
.../beam/runners/prism/internal/worker/worker.go | 18 +-
.../beam/fn/harness/debug/OutputSampler.java | 12 +-
.../beam/fn/harness/debug/OutputSamplerTest.java | 8 +-
.../beam/sdk/io/jdbc/JdbcSchemaIOProvider.java | 5 +-
.../beam/sdk/io/jdbc/JdbcSchemaIOProviderTest.java | 44 +-
.../apache_beam/examples/inference/README.md | 56 ++
...=> pytorch_model_per_key_image_segmentation.py} | 111 ++-
.../apache_beam/examples/ml_transform}/__init__.py | 0
.../examples/ml_transform/ml_transform_basic.py | 1 -
.../examples/ml_transform/ml_transform_it_test.py | 106 +++
.../ml_transform/vocab_tfidf_processing.py | 190 +++++
sdks/python/apache_beam/ml/inference/base.py | 16 +-
sdks/python/apache_beam/ml/inference/base_test.py | 25 +
.../ml/inference/pytorch_inference_it_test.py | 48 ++
.../benchmarks/cloudml/cloudml_benchmark_test.py | 1 -
sdks/python/apache_beam/yaml/yaml_transform.py | 14 +-
.../apache_beam/yaml/yaml_transform_unit_test.py | 854 ++++++++++++++++++++-
sdks/typescript/package-lock.json | 14 +-
sdks/typescript/package.json | 2 +-
.../en/contribute/ptransform-style-guide.md | 1 +
33 files changed, 1729 insertions(+), 126 deletions(-)
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/web/debugz.go
copy sdks/go/pkg/beam/runners/prism/internal/web/{index.html => debugz.html}
(75%)
copy sdks/python/apache_beam/examples/inference/{pytorch_image_segmentation.py
=> pytorch_model_per_key_image_segmentation.py} (62%)
copy {examples/notebooks/notebook_test_scripts =>
sdks/python/apache_beam/examples/ml_transform}/__init__.py (100%)
create mode 100644
sdks/python/apache_beam/examples/ml_transform/ml_transform_it_test.py
create mode 100644
sdks/python/apache_beam/examples/ml_transform/vocab_tfidf_processing.py
