bulk-cdk-core-load/io.airbyte.cdk.load.message/DestinationMessageFactory

DestinationMessageFactory

@Singleton
class DestinationMessageFactory(catalog: DestinationCatalog, @Value(value = "${airbyte.destination.core.file-transfer.enabled}") fileTransferEnabled: Boolean, @Named(value = "requireCheckpointIdOnRecordAndKeyOnState") requireCheckpointIdOnRecordAndKeyOnState: Boolean = false, namespaceMapper: NamespaceMapper, uuidGenerator: UUIDGenerator)

Constructors

Link copied to clipboard
constructor(catalog: DestinationCatalog, @Value(value = "${airbyte.destination.core.file-transfer.enabled}") fileTransferEnabled: Boolean, @Named(value = "requireCheckpointIdOnRecordAndKeyOnState") requireCheckpointIdOnRecordAndKeyOnState: Boolean = false, namespaceMapper: NamespaceMapper, uuidGenerator: UUIDGenerator)

Functions

Link copied to clipboard
fun fromAirbyteProtobufMessage(message: AirbyteMessage.AirbyteMessageProtobuf, serializedSizeBytes: Long): DestinationMessage
Link copied to clipboard
fun fromAirbyteProtocolMessage(message: AirbyteMessage, serializedSizeBytes: Long): DestinationMessage