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

DefaultDestinationCatalogFactory

@Factory
class DefaultDestinationCatalogFactory

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
@Requires(property = "airbyte.connector.operation", value = "check")
@Singleton
fun checkCatalog(@Named(value = "checkNamespace") checkNamespace: String?, namespaceMapper: NamespaceMapper): DestinationCatalog

Warning: Most destinations do not use this.

Link copied to clipboard
@Requires(property = "airbyte.connector.operation", notEquals = "check")
@Singleton
fun syncCatalog(catalog: ConfiguredAirbyteCatalog, streamFactory: DestinationStreamFactory, tableNameResolver: TableNameResolver, namespaceMapper: NamespaceMapper): DestinationCatalog