-
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
CDK module changes for destination #36588
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
This stack of pull requests is managed by Graphite. Learn more about stacking. |
...res/kotlin/io/airbyte/cdk/integrations/standardtest/destination/DestinationAcceptanceTest.kt
Outdated
Show resolved
Hide resolved
...estFixtures/kotlin/io/airbyte/cdk/integrations/standardtest/destination/TestingNamespaces.kt
Show resolved
Hide resolved
c44486f
to
5610dfe
Compare
fun uploadManifest(bucketName: String, manifestFilePath: String, manifestContents: String) { | ||
s3Client.putObject(s3Config.bucketName, manifestFilePath, manifestContents) | ||
} | ||
|
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.
This method got nuked out of orbit.. diff is just resurrection.
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.
oops
183757d
to
d396108
Compare
airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/io/IOs.kt
Show resolved
Hide resolved
...-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/jackson/MoreMappers.kt
Show resolved
Hide resolved
@@ -44,9 +44,10 @@ object Jsons { | |||
private val YAML_OBJECT_MAPPER: ObjectMapper = MoreMappers.initYamlMapper(YAMLFactory()) |
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.
This whole class should be just companion object.
See this comment inline on Graphite.
224bcb8
to
7466653
Compare
...a/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/validation/json/JsonSchemaValidator.kt
Outdated
Show resolved
Hide resolved
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.
🚢
7466653
to
08d1dcd
Compare
9370fc8
to
cd4a7c2
Compare
airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/string/Strings.kt
Outdated
Show resolved
Hide resolved
@@ -14,18 +14,8 @@ package io.airbyte.integrations.base.destination.typing_deduping | |||
* Useful if a destination warehouse handles columns ignoring case, but preserves case in the table | |||
* schema. | |||
*/ | |||
class ColumnId(name: String, originalName: String, canonicalName: String) { | |||
data class ColumnId(val name: String, val originalName: String, val canonicalName: String) { |
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
) { | ||
val rawTableExists: Boolean | ||
val hasUnprocessedRecords: Boolean | ||
data class InitialRawTableStatus( |
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
@@ -58,7 +58,7 @@ abstract class BaseSqlGeneratorIntegrationTest<DestinationState : MinimumDestina | |||
protected var cdcIncrementalAppendStream: StreamConfig? = null | |||
|
|||
protected var generator: SqlGenerator? = null | |||
protected abstract var destinationHandler: DestinationHandler<DestinationState> | |||
protected abstract val destinationHandler: DestinationHandler<DestinationState> |
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.
not sure why it was defined as a var... Much better as a val. How did you find it?
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.
making var generated abstract setDestinationHandler
method which was never intended to be, just getDestinationHandler
...es/kotlin/io/airbyte/integrations/base/destination/typing_deduping/BaseTypingDedupingTest.kt
Outdated
Show resolved
Hide resolved
cd4a7c2
to
f302124
Compare
### TL;DR Updated JDBC and S3 destination to compile destination-redshift
TL;DR
Updated JDBC and S3 destination configurations.