This is an automated email from the ASF dual-hosted git repository.
kkucharczyk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 3558c96 Merge pull request #12149: [BEAM-9897] Add cross-language
support to SnowflakeIO.Read
add 86b8326 Merge pull request #12151: [BEAM-9896] Add streaming for
SnowflakeIO.Write to Java SDK
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
sdks/java/io/snowflake/build.gradle | 1 +
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 588 ++++++++++++++++++---
.../sdk/io/snowflake/SnowflakePipelineOptions.java | 9 +-
.../{package-info.java => StreamingLogLevel.java} | 7 +-
.../sdk/io/snowflake/services/ServiceConfig.java | 4 +
...onfig.java => SnowflakeBatchServiceConfig.java} | 67 ++-
...iceImpl.java => SnowflakeBatchServiceImpl.java} | 64 ++-
.../io/snowflake/services/SnowflakeService.java | 2 -
.../services/SnowflakeStreamingServiceConfig.java | 71 +++
.../services/SnowflakeStreamingServiceImpl.java | 72 +++
...mpl.java => FakeSnowflakeBatchServiceImpl.java} | 13 +-
...e-info.java => FakeSnowflakeIngestManager.java} | 19 +-
.../test/FakeSnowflakeStreamingServiceImpl.java | 73 +++
.../beam/sdk/io/snowflake/test/TestUtils.java | 4 +
.../test/unit/read/SnowflakeIOReadTest.java | 18 +-
.../test/unit/write/CreateDispositionTest.java | 4 +-
.../unit/write/QueryDispositionLocationTest.java | 6 +-
.../test/unit/write/SchemaDispositionTest.java | 4 +-
.../test/unit/write/SnowflakeIOWriteTest.java | 70 ++-
.../test/unit/write/StreamingWriteTest.java | 321 +++++++++++
21 files changed, 1283 insertions(+), 135 deletions(-)
copy
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/enums/{package-info.java
=> StreamingLogLevel.java} (94%)
rename
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/{SnowflakeServiceConfig.java
=> SnowflakeBatchServiceConfig.java} (60%)
rename
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/{SnowflakeServiceImpl.java
=> SnowflakeBatchServiceImpl.java} (79%)
create mode 100644
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeStreamingServiceConfig.java
create mode 100644
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeStreamingServiceImpl.java
rename
sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/{FakeSnowflakeServiceImpl.java
=> FakeSnowflakeBatchServiceImpl.java} (89%)
copy
sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/{package-info.java
=> FakeSnowflakeIngestManager.java} (70%)
create mode 100644
sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/FakeSnowflakeStreamingServiceImpl.java
create mode 100644
sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/write/StreamingWriteTest.java
