This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 73ea0b72c12 [Prism] Honor the resume delay of self-checkpointing SDF
residuals (#39849)
add c267ce6520f Bump github.com/fsouza/fake-gcs-server from 1.55.1 to
1.56.0 in /sdks (#39890)
add 571184a509e Add Vertex Model Monitoring to CHANGES.md (#39882)
add 87e31bd8a31 Update build.gradle.kts (#39892)
add 167b8649fc9 [Java] Bound the Watch deduplication state with a
timestamp cursor (#39746)
add b2013e09f91 Fix ZeroDivisionError at initial invocation of
monitoring_info when there is no work yet (#39885)
add c494cc647fb Feat: expanding the context of the second and third
security layers of testPubSubContext so that, in the event of failure,
subscriptions retain a 24-hour grace period before being deleted (#39856)
add 1fca1c2d371 prevent cloudML TFT extras from replacing the SDK under
test (#39884)
add 69f7fd48a0c Add Snowflake YAML write transform
add 85bad221c71 Add Snowflake Read and Streaming Write
add 90c93d7f541 Fix bytes
add d131e0e74b7 Fix imports
add f4e62fdafbf Refactoring
add 15efa5d2084 Add extended test
add b275c84f8e2 Add license
add 27c4e6395cb Move depends
add a93fdcdda75 Fix jms yaml
add da201e642a2 Fix import Nullable
add 497870ade99 Change to provided
add 8cfbd8e01c2 Merge pull request #39742 from apache/snowflakeio-yaml
add ad39be0f58b Clarify service account key issue reports (#39894)
No new revisions were added by this update.
Summary of changes:
.../beam_CloudML_Benchmarks_Dataflow.json | 2 +-
.test-infra/tools/stale_cleaner.py | 7 +
CHANGES.md | 2 +
build.gradle.kts | 14 +-
infra/enforcement/README.md | 4 +-
infra/enforcement/account_keys.py | 9 +-
infra/enforcement/sending.py | 10 +-
infra/enforcement/test_sending.py | 6 +-
sdks/go.mod | 9 +-
sdks/go.sum | 29 +-
.../java/org/apache/beam/sdk/transforms/Watch.java | 239 +++++++++-
.../org/apache/beam/sdk/transforms/WatchTest.java | 348 ++++++++++++++-
sdks/java/io/snowflake/build.gradle | 2 +
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 3 +-
.../SnowflakeReadSchemaTransformProvider.java | 289 ++++++++++++
.../snowflake/SnowflakeSchemaTransformUtils.java | 342 ++++++++++++++
.../io/snowflake/SnowflakeWriteConfiguration.java | 227 ++++++++++
.../SnowflakeWriteSchemaTransformProvider.java | 179 ++++++++
.../SnowflakeReadSchemaTransformProviderTest.java | 311 +++++++++++++
.../SnowflakeWriteSchemaTransformProviderTest.java | 494 +++++++++++++++++++++
sdks/python/apache_beam/io/iobase.py | 12 +-
sdks/python/apache_beam/io/iobase_test.py | 21 +
.../yaml/extended_tests/databases/snowflake.yaml | 90 ++++
sdks/python/apache_beam/yaml/integration_tests.py | 35 ++
sdks/python/apache_beam/yaml/standard_io.yaml | 56 +++
sdks/python/build.gradle | 2 +-
sdks/python/test-suites/dataflow/common.gradle | 6 +-
27 files changed, 2679 insertions(+), 69 deletions(-)
create mode 100644
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeReadSchemaTransformProvider.java
create mode 100644
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeSchemaTransformUtils.java
create mode 100644
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeWriteConfiguration.java
create mode 100644
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeWriteSchemaTransformProvider.java
create mode 100644
sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/SnowflakeReadSchemaTransformProviderTest.java
create mode 100644
sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/SnowflakeWriteSchemaTransformProviderTest.java
create mode 100644
sdks/python/apache_beam/yaml/extended_tests/databases/snowflake.yaml
