jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-19 18:14:56 -05:00
Code Issues Packages Projects Releases Wiki Activity

style: Apply spotless formatting to Kotlin files

Browse Source 
Co-Authored-By: Ilja Herdt <ilja.herdt@airbyte.io>
This commit is contained in:
Devin AI
2025-12-18 22:33:03 +00:00
parent a2d78d1931
commit dd147051af
2 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
airbyte-integrations/connectors/destination-databricks/src/main/kotlin/io/airbyte/integrations/destination/databricks/DatabricksDestination.kt
View File

@@ -61,7 +61,11 @@ class DatabricksDestination : BaseConnector(), Destination {
val connectorConfig = DatabricksConnectorConfig.deserialize(config)
val datasource = DatabricksConnectorClientsFactory.createDataSource(connectorConfig)
val sqlGenerator =
DatabricksSqlGenerator(DatabricksNamingTransformer(), connectorConfig.database, connectorConfig.enableLiquidClustering)
DatabricksSqlGenerator(
DatabricksNamingTransformer(),
connectorConfig.database,
connectorConfig.enableLiquidClustering
)
val jdbcDatabase = DefaultJdbcDatabase(datasource)
val destinationHandler =
DatabricksDestinationHandler(sqlGenerator, connectorConfig.database, jdbcDatabase)
@@ -212,7 +216,11 @@ class DatabricksDestination : BaseConnector(), Destination {
val connectorConfig = DatabricksConnectorConfig.deserialize(config)
val sqlGenerator =
DatabricksSqlGenerator(DatabricksNamingTransformer(), connectorConfig.database, connectorConfig.enableLiquidClustering)
DatabricksSqlGenerator(
DatabricksNamingTransformer(),
connectorConfig.database,
connectorConfig.enableLiquidClustering
)
val defaultNamespace = connectorConfig.schema
val catalogParser =
CatalogParser(sqlGenerator, defaultNamespace, connectorConfig.rawSchemaOverride)

2
airbyte-integrations/connectors/destination-databricks/src/main/kotlin/io/airbyte/integrations/destination/databricks/model/DatabricksConnectorConfig.kt
View File

@@ -22,7 +22,7 @@ data class DatabricksConnectorConfig(
@JsonProperty("authentication") val authentication: Authentication,
@JsonProperty("purge_staging_data") val purgeStagingData: Boolean = true,
@JsonProperty("enable_liquid_clustering") val enableLiquidClustering: Boolean = false,
){
) {
companion object {
fun deserialize(jsonNode: JsonNode): DatabricksConnectorConfig {
val objectMapper = MoreMappers.initMapper()