Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.command/DestinationCatalog

DestinationCatalog

data class DestinationCatalog(val streams: List<DestinationStream> = emptyList())

Internal representation of destination streams. This is intended to be a case class specialized for usability.

Constructors

DestinationCatalog

constructor(streams: List<DestinationStream> = emptyList())

Properties

val streams: List<DestinationStream>

Functions

asProtocolObject

fun asProtocolObject(): ConfiguredAirbyteCatalog

fun getStream(descriptor: DestinationStream.Descriptor): DestinationStream

fun getStream(name: String, namespace: String?): DestinationStream

fun size(): Int