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
