fix compiler errors

Author: stephane-airbyte

airbyte-cdk/java/airbyte-cdk/azure-destinations/build.gradle

@@ -1,3 +1,9 @@
+compileKotlin {
+    compilerOptions {
+        allWarningsAsErrors = false
+    }
+}
+
 dependencies {
     implementation project(':airbyte-cdk:java:airbyte-cdk:dependencies')
     implementation project(':airbyte-cdk:java:airbyte-cdk:core')

airbyte-cdk/java/airbyte-cdk/azure-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/jdbc/copy/azure/AzureBlobStorageConfig.kt

@@ -6,16 +6,13 @@ package io.airbyte.cdk.integrations.destination.jdbc.copy.azure
 import com.fasterxml.jackson.databind.JsonNode
 import java.util.*
 
-class AzureBlobStorageConfig(private val endpointDomainName: String?,
+class AzureBlobStorageConfig(val endpointDomainName: String = DEFAULT_STORAGE_ENDPOINT_DOMAIN_NAME,
                              val accountName: String,
                              val containerName: String,
                              val sasToken: String) {
-    fun getEndpointDomainName(): String {
-        return endpointDomainName ?: DEFAULT_STORAGE_ENDPOINT_DOMAIN_NAME
-    }
 
     val endpointUrl: String
-        get() = String.format(Locale.ROOT, "https://%s.%s", accountName, getEndpointDomainName())
+        get() = String.format(Locale.ROOT, "https://%s.%s", accountName, endpointDomainName)
 
     companion object {
         private const val DEFAULT_STORAGE_ENDPOINT_DOMAIN_NAME = "blob.core.windows.net"

airbyte-cdk/java/airbyte-cdk/azure-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/jdbc/copy/azure/AzureBlobStorageStreamCopier.kt

@@ -39,19 +39,14 @@ abstract class AzureBlobStorageStreamCopier(protected val stagingFolder: String,
                                             private val nameTransformer: StandardNameTransformer,
                                             private val sqlOperations: SqlOperations) : StreamCopier {
     protected var filenameGenerator: StagingFilenameGenerator = StagingFilenameGenerator(streamName, GlobalDataSizeConstants.DEFAULT_MAX_BATCH_SIZE_BYTES.toLong())
-    protected val azureStagingFiles: MutableSet<String?> = HashSet()
+    protected val azureStagingFiles: MutableSet<String> = HashSet()
 
     @get:VisibleForTesting
     val tmpTableName: String = nameTransformer.getTmpTableName(streamName)
     protected val activeStagingWriterFileNames: MutableSet<String?> = HashSet()
     private val csvPrinters = HashMap<String?, CSVPrinter>()
     private val blobClients = HashMap<String?, AppendBlobClient>()
-    override var currentFile: String? = null
-        private set
-
-    fun getAzureStagingFiles(): Set<String?> {
-        return azureStagingFiles
-    }
+    override lateinit var currentFile: String
 
     @Throws(Exception::class)
     override fun write(id: UUID?, recordMessage: AirbyteRecordMessage?, azureFileName: String?) {

airbyte-cdk/java/airbyte-cdk/azure-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/jdbc/copy/azure/AzureBlobStorageStreamCopierFactory.kt

@@ -13,7 +13,7 @@ import io.airbyte.cdk.integrations.destination.jdbc.copy.StreamCopierFactory.Com
 import io.airbyte.protocol.models.v0.ConfiguredAirbyteStream
 import io.airbyte.protocol.models.v0.DestinationSyncMode
 
-abstract class AzureBlobStorageStreamCopierFactory : StreamCopierFactory<AzureBlobStorageConfig?> {
+abstract class AzureBlobStorageStreamCopierFactory : StreamCopierFactory<AzureBlobStorageConfig> {
     override fun create(configuredSchema: String?,
                         azureBlobConfig: AzureBlobStorageConfig,
                         stagingFolder: String?,

airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/destination/jdbc/copy/StreamCopier.kt

@@ -65,5 +65,5 @@ interface StreamCopier {
     fun prepareStagingFile(): String?
 
     /** @return current staging file name */
-    val currentFile: String?
+    val currentFile: String
 }