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

DestinationMessageFactory

@Singleton
class DestinationMessageFactory(catalog: DestinationCatalog, @Named(value = "dataChannelMedium") dataChannelMedium: DataChannelMedium, namespaceMapper: NamespaceMapper, uuidGenerator: UUIDGenerator)

Constructors

Link copied to clipboard
constructor(catalog: DestinationCatalog, @Named(value = "dataChannelMedium") dataChannelMedium: DataChannelMedium, 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