rename class

Author: edgao

airbyte-cdk/bulk/toolkits/load-db/src/main/kotlin/io/airbyte/cdk/load/orchestration/db/DestinationInitialStatusGatherer.kt renamed to airbyte-cdk/bulk/toolkits/load-db/src/main/kotlin/io/airbyte/cdk/load/orchestration/db/DatabaseInitialStatusGatherer.kt

@@ -7,7 +7,7 @@ package io.airbyte.cdk.load.orchestration.db
 import io.airbyte.cdk.load.command.DestinationStream
 import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.TableCatalog
 
-interface DestinationInitialStatus
+interface DatabaseInitialStatus
 
 /**
  * Some destinations can efficiently fetch multiple tables' information in a single query, so this
@@ -23,6 +23,6 @@ interface DestinationInitialStatus
  * }
  * ```
  */
-fun interface DestinationInitialStatusGatherer<InitialStatus : DestinationInitialStatus> {
+fun interface DatabaseInitialStatusGatherer<InitialStatus : DatabaseInitialStatus> {
     suspend fun gatherInitialStatus(streams: TableCatalog): Map<DestinationStream, InitialStatus>
 }

airbyte-cdk/bulk/toolkits/load-db/src/main/kotlin/io/airbyte/cdk/load/orchestration/db/legacy_typing_deduping/TypingDedupingDestinationInitialStatus.kt renamed to airbyte-cdk/bulk/toolkits/load-db/src/main/kotlin/io/airbyte/cdk/load/orchestration/db/legacy_typing_deduping/TypingDedupingDatabaseInitialStatus.kt

@@ -4,15 +4,15 @@
 
 package io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping
 
-import io.airbyte.cdk.load.orchestration.db.DestinationInitialStatus
+import io.airbyte.cdk.load.orchestration.db.DatabaseInitialStatus
 import java.time.Instant
 
-data class TypingDedupingDestinationInitialStatus(
+data class TypingDedupingDatabaseInitialStatus(
     /** Initial status of the final table, or null if the table doesn't exist yet. */
     val finalTableStatus: FinalTableInitialStatus?,
     val rawTableStatus: RawTableInitialStatus?,
     val tempRawTableStatus: RawTableInitialStatus?,
-) : DestinationInitialStatus
+) : DatabaseInitialStatus
 
 data class FinalTableInitialStatus(
     val isSchemaMismatch: Boolean,

airbyte-cdk/bulk/toolkits/load-db/src/main/kotlin/io/airbyte/cdk/load/orchestration/db/legacy_typing_deduping/TypingDedupingStreamLoader.kt

@@ -18,7 +18,7 @@ private val logger = KotlinLogging.logger {}
 
 class TypingDedupingStreamLoader(
     override val stream: DestinationStream,
-    private val initialStatus: TypingDedupingDestinationInitialStatus,
+    private val initialStatus: TypingDedupingDatabaseInitialStatus,
     private val tableNames: TableNames,
     private val columnNameMapping: ColumnNameMapping,
     private val rawTableOperations: TypingDedupingRawTableOperations,

airbyte-cdk/bulk/toolkits/load-db/src/main/kotlin/io/airbyte/cdk/load/orchestration/db/legacy_typing_deduping/TypingDedupingWriter.kt

@@ -6,7 +6,7 @@ package io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping
 
 import io.airbyte.cdk.load.command.DestinationStream
 import io.airbyte.cdk.load.orchestration.db.DatabaseHandler
-import io.airbyte.cdk.load.orchestration.db.DestinationInitialStatusGatherer
+import io.airbyte.cdk.load.orchestration.db.DatabaseInitialStatusGatherer
 import io.airbyte.cdk.load.write.DestinationWriter
 import io.airbyte.cdk.load.write.StreamLoader
 import java.util.concurrent.Executors
@@ -16,15 +16,14 @@ import kotlinx.coroutines.runBlocking
 
 class TypingDedupingWriter(
     private val names: TableCatalog,
-    private val stateGatherer:
-        DestinationInitialStatusGatherer<TypingDedupingDestinationInitialStatus>,
+    private val stateGatherer: DatabaseInitialStatusGatherer<TypingDedupingDatabaseInitialStatus>,
     private val databaseHandler: DatabaseHandler,
     private val rawTableOperations: TypingDedupingRawTableOperations,
     private val finalTableOperations: TypingDedupingFinalTableOperations,
     private val disableTypeDedupe: Boolean,
 ) : DestinationWriter {
     private lateinit var initialStatuses:
-        Map<DestinationStream, TypingDedupingDestinationInitialStatus>
+        Map<DestinationStream, TypingDedupingDatabaseInitialStatus>
 
     override suspend fun setup() {
         Executors.newFixedThreadPool(4).asCoroutineDispatcher().use { dispatcher ->
@@ -34,7 +33,7 @@ class TypingDedupingWriter(
             databaseHandler.createNamespaces(namespaces.toSet())
 
             val initialInitialStatuses:
-                Map<DestinationStream, TypingDedupingDestinationInitialStatus> =
+                Map<DestinationStream, TypingDedupingDatabaseInitialStatus> =
                 stateGatherer.gatherInitialStatus(names)
 
             // TODO migrations - we should probably actually drop all existing migrations as part of

airbyte-integrations/connectors/destination-bigquery/src/main/kotlin/io/airbyte/integrations/destination/bigquery/typing_deduping/BigqueryDestinationInitialStatusGatherer.kt renamed to airbyte-integrations/connectors/destination-bigquery/src/main/kotlin/io/airbyte/integrations/destination/bigquery/typing_deduping/BigqueryDatabaseInitialStatusGatherer.kt

@@ -20,14 +20,14 @@ import io.airbyte.cdk.load.command.Overwrite
 import io.airbyte.cdk.load.data.ObjectType
 import io.airbyte.cdk.load.message.Meta
 import io.airbyte.cdk.load.orchestration.db.ColumnNameMapping
-import io.airbyte.cdk.load.orchestration.db.DestinationInitialStatusGatherer
+import io.airbyte.cdk.load.orchestration.db.DatabaseInitialStatusGatherer
 import io.airbyte.cdk.load.orchestration.db.TableName
 import io.airbyte.cdk.load.orchestration.db.TableNames
 import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.AlterTableReport
 import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.FinalTableInitialStatus
 import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.RawTableInitialStatus
 import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.TableCatalog
-import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.TypingDedupingDestinationInitialStatus
+import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.TypingDedupingDatabaseInitialStatus
 import io.airbyte.cdk.util.CollectionUtils.containsAllIgnoreCase
 import io.airbyte.cdk.util.CollectionUtils.containsIgnoreCase
 import io.airbyte.cdk.util.CollectionUtils.matchingKey
@@ -38,8 +38,8 @@ import java.util.stream.Stream
 
 private val logger = KotlinLogging.logger {}
 
-class BigqueryDestinationInitialStatusGatherer(private val bq: BigQuery) :
-    DestinationInitialStatusGatherer<TypingDedupingDestinationInitialStatus> {
+class BigqueryDatabaseInitialStatusGatherer(private val bq: BigQuery) :
+    DatabaseInitialStatusGatherer<TypingDedupingDatabaseInitialStatus> {
     private fun findExistingTable(finalTableName: TableName): TableDefinition? {
         val table = bq.getTable(finalTableName.namespace, finalTableName.name)
         return table?.getDefinition()
@@ -116,7 +116,7 @@ class BigqueryDestinationInitialStatusGatherer(private val bq: BigQuery) :
 
     override suspend fun gatherInitialStatus(
         streams: TableCatalog,
-    ): Map<DestinationStream, TypingDedupingDestinationInitialStatus> {
+    ): Map<DestinationStream, TypingDedupingDatabaseInitialStatus> {
         return streams.mapValues { (stream, names) ->
             val (tableNames, columnNameMapping) = names
             val finalTable = findExistingTable(tableNames.finalTableName!!)
@@ -143,7 +143,7 @@ class BigqueryDestinationInitialStatusGatherer(private val bq: BigQuery) :
                     tableNames.rawTableName!!,
                     TableNames.TMP_TABLE_SUFFIX,
                 )
-            TypingDedupingDestinationInitialStatus(
+            TypingDedupingDatabaseInitialStatus(
                 finalTableStatus,
                 rawTableState,
                 tempRawTableState,

airbyte-integrations/connectors/destination-bigquery/src/main/kotlin/io/airbyte/integrations/destination/bigquery/write/BigqueryWriter.kt

@@ -11,7 +11,7 @@ import io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping.TypingDedupin
 import io.airbyte.integrations.destination.bigquery.spec.BigqueryConfiguration
 import io.airbyte.integrations.destination.bigquery.typing_deduping.BigQueryDatabaseHandler
 import io.airbyte.integrations.destination.bigquery.typing_deduping.BigQuerySqlGenerator
-import io.airbyte.integrations.destination.bigquery.typing_deduping.BigqueryDestinationInitialStatusGatherer
+import io.airbyte.integrations.destination.bigquery.typing_deduping.BigqueryDatabaseInitialStatusGatherer
 import io.micronaut.context.annotation.Factory
 import jakarta.inject.Singleton
 
@@ -26,7 +26,7 @@ class BigqueryWriterFactory(
         val destinationHandler = BigQueryDatabaseHandler(bigquery, config.datasetLocation.region)
         return TypingDedupingWriter(
             names,
-            BigqueryDestinationInitialStatusGatherer(bigquery),
+            BigqueryDatabaseInitialStatusGatherer(bigquery),
             destinationHandler,
             BigqueryRawTableOperations(bigquery),
             TypingDedupingFinalTableOperations(