You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2020/09/03 21:55:18 UTC
[beam] branch master updated (6d2c91f -> 1bdc859)
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6d2c91f Merge pull request #12761 from [BEAM-10853] Fixing copy name issue: Single name for all copies
add 1bdc859 Merge pull request #12618 from [BEAM-10669] Add support for Dataflow Templates in SnowflakeIO
No new revisions were added by this update.
Summary of changes:
build.gradle | 3 +-
...SnowflakeCredentials.java => KeyPairUtils.java} | 42 +-
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 638 ++++++++++++++-------
.../sdk/io/snowflake/SnowflakePipelineOptions.java | 61 +-
.../OAuthTokenSnowflakeCredentials.java | 31 -
.../credentials/SnowflakeCredentials.java | 24 -
.../credentials/SnowflakeCredentialsFactory.java | 69 ---
.../UsernamePasswordSnowflakeCredentials.java | 37 --
.../sdk/io/snowflake/credentials/package-info.java | 20 -
.../io/snowflake/crosslanguage/ReadBuilder.java | 6 +-
.../io/snowflake/crosslanguage/WriteBuilder.java | 6 +-
.../services/SnowflakeBatchServiceConfig.java | 2 +-
.../sdk/io/snowflake/test/BatchSnowflakeIOIT.java | 21 +-
.../io/snowflake/test/StreamingSnowflakeIOIT.java | 7 +-
.../test/TestSnowflakePipelineOptions.java} | 30 +-
.../beam/sdk/io/snowflake/test/TestUtils.java | 39 +-
.../test/unit/DataSourceConfigurationTest.java | 192 ++++++-
.../snowflake/test/unit/TestPipelineOptions.java | 28 -
.../KeyPairSnowflakeCredentialsTest.java | 38 --
.../OAuthTokenSnowflakeCredentialsTest.java | 46 --
.../SnowflakeCredentialsFactoryTest.java | 77 ---
.../UsernamePasswordSnowflakeCredentialsTest.java | 50 --
.../test/unit/read/SnowflakeIOReadTest.java | 6 +-
.../test/unit/write/CreateDispositionTest.java | 8 +-
.../unit/write/QueryDispositionLocationTest.java | 8 +-
.../test/unit/write/SchemaDispositionTest.java | 8 +-
.../test/unit/write/SnowflakeIOWriteTest.java | 8 +-
.../test/unit/write/StreamingWriteTest.java | 38 +-
.../src/test/resources/invalid_test_rsa_key.p8 | 3 +
.../{test_rsa_key.p8 => valid_test_rsa_key.p8} | 0
30 files changed, 780 insertions(+), 766 deletions(-)
rename sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/{credentials/KeyPairSnowflakeCredentials.java => KeyPairUtils.java} (64%)
delete mode 100644 sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/credentials/OAuthTokenSnowflakeCredentials.java
delete mode 100644 sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/credentials/SnowflakeCredentials.java
delete mode 100644 sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/credentials/SnowflakeCredentialsFactory.java
delete mode 100644 sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/credentials/UsernamePasswordSnowflakeCredentials.java
delete mode 100644 sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/credentials/package-info.java
copy sdks/java/io/snowflake/src/{main/java/org/apache/beam/sdk/io/snowflake/SnowflakePipelineOptions.java => test/java/org/apache/beam/sdk/io/snowflake/test/TestSnowflakePipelineOptions.java} (85%)
delete mode 100644 sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/TestPipelineOptions.java
delete mode 100644 sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/credentials/KeyPairSnowflakeCredentialsTest.java
delete mode 100644 sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/credentials/OAuthTokenSnowflakeCredentialsTest.java
delete mode 100644 sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/credentials/SnowflakeCredentialsFactoryTest.java
delete mode 100644 sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/credentials/UsernamePasswordSnowflakeCredentialsTest.java
create mode 100644 sdks/java/io/snowflake/src/test/resources/invalid_test_rsa_key.p8
rename sdks/java/io/snowflake/src/test/resources/{test_rsa_key.p8 => valid_test_rsa_key.p8} (100%)