-
Notifications
You must be signed in to change notification settings - Fork 4.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Destination Snowflake: Adapting to new connector interfaces #38658
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
This stack of pull requests is managed by Graphite. Learn more about stacking. |
5e75798
to
253d173
Compare
253d173
to
179acf1
Compare
179acf1
to
a4b2454
Compare
...ke/src/test/java/io/airbyte/integrations/destination/snowflake/SnowflakeDestinationTest.java
Outdated
Show resolved
Hide resolved
.../integrations/destination/snowflake/typing_deduping/AbstractSnowflakeTypingDedupingTest.java
Outdated
Show resolved
Hide resolved
ffd128a
to
3561bea
Compare
f8940bd
to
51fc839
Compare
51fc839
to
e70753c
Compare
@@ -15,12 +15,6 @@ java { | |||
} | |||
} | |||
|
|||
compileKotlin { | |||
compilerOptions { | |||
allWarningsAsErrors = false |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thank you
e70753c
to
cd59d77
Compare
cd59d77
to
55cb64c
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
structure seems solid (no surprise, given that we already went through most of this with bigquery)
had some in-depth comments for specific files though
...wflake/src/main/kotlin/io/airbyte/integrations/destination/snowflake/SnowflakeDestination.kt
Show resolved
Hide resolved
...wflake/src/main/kotlin/io/airbyte/integrations/destination/snowflake/SnowflakeDestination.kt
Show resolved
Hide resolved
...kotlin/io/airbyte/integrations/destination/snowflake/operation/SnowflakeStagingClientTest.kt
Show resolved
Hide resolved
...ain/kotlin/io/airbyte/integrations/destination/snowflake/operation/SnowflakeStagingClient.kt
Show resolved
Hide resolved
...ain/kotlin/io/airbyte/integrations/destination/snowflake/operation/SnowflakeStagingClient.kt
Show resolved
Hide resolved
...io/airbyte/integrations/destination/snowflake/typing_deduping/SnowflakeDestinationHandler.kt
Show resolved
Hide resolved
...io/airbyte/integrations/destination/snowflake/typing_deduping/SnowflakeDestinationHandler.kt
Show resolved
Hide resolved
...egration/kotlin/io/airbyte/integrations/destination/snowflake/SnowflakeTestDataComparator.kt
Show resolved
Hide resolved
...irbyte/integrations/destination/snowflake/typing_deduping/SnowflakeDestinationHandlerTest.kt
Outdated
Show resolved
Hide resolved
...irbyte/integrations/destination/snowflake/typing_deduping/SnowflakeDestinationHandlerTest.kt
Outdated
Show resolved
Hide resolved
55cb64c
to
63003aa
Compare
aa9c96a
to
334749f
Compare
334749f
to
fd81a2c
Compare
fd81a2c
to
3b341f8
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚛
What
Adapting Snowflake to use #38107
Fixes: #34819
Review guide
Important logic in deleted classes in moved to
SnowflakeStagingClient
andSnowflakeStorageOperations
.Rest of the code is just adapting to the newer interface by injecting
StorageOperations
.Additionally, cleaning up warnings and idiomatic fixes after Kotlin auto-conversion.
User Impact
Can this PR be safely reverted and rolled back?