keep rawData private

Author: frifriSF59

airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/message/DestinationMessage.kt

@@ -183,9 +183,13 @@ data class EnrichedDestinationRecordAirbyteValue(
 
 data class DestinationRecordRaw(
     val stream: DestinationStream.Descriptor,
-    val rawData: AirbyteMessage,
-    val serialized: String
+    private val rawData: AirbyteMessage,
+    private val serialized: String
 ) {
+    fun asRawJson(): JsonNode {
+        return rawData.record.data as JsonNode
+    }
+
     fun asDestinationRecordAirbyteValue(): DestinationRecordAirbyteValue {
         return DestinationRecordAirbyteValue(
             stream,
@@ -198,6 +202,10 @@ data class DestinationRecordRaw(
             serialized.length.toLong()
         )
     }
+
+    fun asEnrichedDestinationRecordAirbyteValue(): EnrichedDestinationRecordAirbyteValue {
+        TODO()
+    }
 }
 
 data class DestinationFile(

airbyte-integrations/connectors/destination-s3-data-lake/src/main/kotlin/io/airbyte/integrations/destination/s3_data_lake/S3DataLakePartitioner.kt

@@ -34,7 +34,7 @@ class S3DataLakePartitioner(catalog: DestinationCatalog) : InputPartitioner {
         }
 
         streamToPrimaryKeyFieldNames[record.stream]?.let { primaryKey ->
-            val jsonData = record.rawData.record.data as JsonNode
+            val jsonData = record.asRawJson()
 
             val primaryKeyValues = primaryKey.map { keys ->
                 keys.map { key ->