You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2026/08/26 19:47:07 UTC

(beam) branch master updated (1fca1c2d371 -> 8cfbd8e01c2)

This is an automated email from the ASF dual-hosted git repository.

Amar3tto pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 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
     new 8cfbd8e01c2 Merge pull request #39742 from apache/snowflakeio-yaml

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 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 +++++++++++++++++++++
 .../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 +-
 12 files changed, 2028 insertions(+), 2 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

(beam) 01/01: Merge pull request #39742 from apache/snowflakeio-yaml

Posted by vt...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

Amar3tto pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 8cfbd8e01c2c80e98ecb99f75ab9c0909a9403cc
Merge: 1fca1c2d371 497870ade99
Author: Vitaly Terentyev <vi...@gmail.com>
AuthorDate: Wed Aug 26 23:46:57 2026 +0400

    Merge pull request #39742 from apache/snowflakeio-yaml
    
    SnowflakeIO yaml

 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 +++++++++++++++++++++
 .../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 +-
 12 files changed, 2028 insertions(+), 2 deletions(-)