bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.transform

Package-level declarations

Types

data class RecordDTO(val fields: Map<String, AirbyteValue>, val partitionKey: PartitionKey, val sizeBytes: Long, val emittedAtMs: Long)

Data transfer object containing a transformed record ready for aggregation and loading.

sealed interface ValidationResult

Result of a value validation check via the ValueCoercer.validate method.

Interface for destination-specific field coercion and type representation.