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

Package-level declarations

Types

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

Internal DTO for passing of record data with minimal metadata.

Link copied to clipboard
sealed interface ValidationResult

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

Link copied to clipboard
interface ValueCoercer

Interface for destination-specific field coercion and type representation.