DevNullDirectLoader fix

Author: frifriSF59

airbyte-integrations/connectors/destination-dev-null/src/main/kotlin/io/airbyte/integrations/destination/dev_null/DevNullDirectLoader.kt

@@ -5,7 +5,7 @@
 package io.airbyte.integrations.destination.dev_null
 
 import io.airbyte.cdk.load.command.DestinationStream
-import io.airbyte.cdk.load.message.DestinationRecordAirbyteValue
+import io.airbyte.cdk.load.message.DestinationRecordRaw
 import io.airbyte.cdk.load.write.DirectLoader
 import io.airbyte.cdk.load.write.DirectLoaderFactory
 import io.github.oshai.kotlinlogging.KotlinLogging
@@ -18,9 +18,9 @@ abstract class DevNullDirectLoader(
 ) : DirectLoader {
     private var recordCount: Long = 0L
 
-    abstract fun acceptInner(record: DestinationRecordAirbyteValue)
+    abstract fun acceptInner(record: DestinationRecordRaw)
 
-    override fun accept(record: DestinationRecordAirbyteValue): DirectLoader.DirectLoadResult {
+    override fun accept(record: DestinationRecordRaw): DirectLoader.DirectLoadResult {
         acceptInner(record)
         return if (++recordCount % config.ackRatePerRecord == 0L) {
             DirectLoader.Complete
@@ -87,7 +87,7 @@ class LoggingDirectLoader(
     private var logCount: Long = 0L
     private val prng: Random = loggingConfig.seed?.let { Random(it) } ?: Random.Default
 
-    override fun acceptInner(record: DestinationRecordAirbyteValue) {
+    override fun acceptInner(record: DestinationRecordRaw) {
         if (recordCount++ % loggingConfig.logEvery == 0L) {
             if (loggingConfig.sampleRate == 1.0 || prng.nextDouble() < loggingConfig.sampleRate) {
                 if (++logCount < loggingConfig.maxEntryCount) {
@@ -101,15 +101,15 @@ class LoggingDirectLoader(
 }
 
 class SilentDirectLoader(config: DevNullConfiguration) : DevNullDirectLoader(config) {
-    override fun acceptInner(record: DestinationRecordAirbyteValue) {
+    override fun acceptInner(record: DestinationRecordRaw) {
         /* Do nothing */
     }
 }
 
 class ThrottledDirectLoader(config: DevNullConfiguration, private val millisPerRecord: Long) :
     DevNullDirectLoader(config) {
 
-    override fun acceptInner(record: DestinationRecordAirbyteValue) {
+    override fun acceptInner(record: DestinationRecordRaw) {
         Thread.sleep(millisPerRecord)
     }
 }
@@ -123,7 +123,7 @@ class FailingDirectLoader(
 
     private var messageCount: Long = 0L
 
-    override fun acceptInner(record: DestinationRecordAirbyteValue) {
+    override fun acceptInner(record: DestinationRecordRaw) {
         if (messageCount++ > numMessages) {
             val message =
                 "Failing Destination(stream=$stream, numMessages=$numMessages: failing at $record)"