bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.command/DefaultDestinationCatalogFactory

DefaultDestinationCatalogFactory

@Factory
class DefaultDestinationCatalogFactory

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
@Singleton
fun getDestinationCatalog(catalog: ConfiguredAirbyteCatalog, streamFactory: DestinationStreamFactory, @Value(value = "${airbyte.connector.operation}") operation: String, @Named(value = "checkNamespace") checkNamespace: String?, namespaceMapper: NamespaceMapper): DestinationCatalog