kotlin things

Author: edgao

airbyte-cdk/java/airbyte-cdk/typing-deduping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/DV2OperationUtils.kt

@@ -48,12 +48,12 @@ class DV2OperationUtils {
         sqlGenerator: SqlGenerator,
         destinationHandler: DestinationHandler,
         parsedCatalog: ParsedCatalog) {
-      val rawSchema = parsedCatalog.streams.stream().map { stream: StreamConfig -> stream.id.rawNamespace }
-      val finalSchema = parsedCatalog.streams.stream().map { stream: StreamConfig -> stream.id.finalNamespace }
+      val rawSchema = parsedCatalog.streams.stream().map { it.id.rawNamespace }
+      val finalSchema = parsedCatalog.streams.stream().map { it.id.finalNamespace }
       val createAllSchemasSql = Streams.concat<String>(rawSchema, finalSchema)
-          .filter { obj: String? -> Objects.nonNull(obj) }
+          .filter(Objects::nonNull)
           .distinct()
-          .map { schema: String? -> sqlGenerator.createSchema(schema) }
+          .map(sqlGenerator::createSchema)
           .toList()
       destinationHandler.execute(Sql.concat(createAllSchemasSql))
     }