PR feedback (factory is bucket; extract cleaner to class)

Author: edgao

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

@@ -0,0 +1,33 @@
+/*
+ * Copyright (c) 2025 Airbyte, Inc., all rights reserved.
+ */
+
+package io.airbyte.integrations.destination.bigquery
+
+import io.airbyte.cdk.load.check.DestinationCheckerSync
+import io.airbyte.cdk.load.command.DestinationCatalog
+import io.airbyte.cdk.load.state.SyncManager
+import io.airbyte.cdk.load.task.DestinationTaskLauncher
+import io.airbyte.cdk.load.write.WriteOperation
+import io.airbyte.integrations.destination.bigquery.check.BigqueryCheckCleaner
+import io.micronaut.context.annotation.Factory
+import jakarta.inject.Named
+import jakarta.inject.Singleton
+import java.io.PipedOutputStream
+
+@Factory
+class BigqueryBeansFactory {
+    @Singleton
+    fun getChecker(
+        catalog: DestinationCatalog,
+        @Named("checkInputStreamPipe") pipe: PipedOutputStream,
+        taskLauncher: DestinationTaskLauncher,
+        syncManager: SyncManager,
+    ) =
+        DestinationCheckerSync(
+            catalog,
+            pipe,
+            WriteOperation(taskLauncher, syncManager),
+            BigqueryCheckCleaner(),
+        )
+}

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

@@ -0,0 +1,27 @@
+/*
+ * Copyright (c) 2025 Airbyte, Inc., all rights reserved.
+ */
+
+package io.airbyte.integrations.destination.bigquery.check
+
+import io.airbyte.cdk.load.check.CheckCleaner
+import io.airbyte.cdk.load.command.DestinationStream
+import io.airbyte.integrations.destination.bigquery.spec.BigqueryConfiguration
+import io.airbyte.integrations.destination.bigquery.typing_deduping.BigqueryFinalTableNameGenerator
+import io.airbyte.integrations.destination.bigquery.typing_deduping.BigqueryRawTableNameGenerator
+import io.airbyte.integrations.destination.bigquery.typing_deduping.toTableId
+import io.airbyte.integrations.destination.bigquery.util.BigqueryClientFactory
+
+class BigqueryCheckCleaner : CheckCleaner<BigqueryConfiguration> {
+    override fun cleanup(config: BigqueryConfiguration, stream: DestinationStream) {
+        val bq = BigqueryClientFactory(config).make()
+        bq.getTable(
+                BigqueryRawTableNameGenerator(config).getTableName(stream.descriptor).toTableId()
+            )
+            ?.delete()
+        bq.getTable(
+                BigqueryFinalTableNameGenerator(config).getTableName(stream.descriptor).toTableId()
+            )
+            ?.delete()
+    }
+}