bulk-cdk-core-extract/io.airbyte.cdk.discover/DiscoverOperation

DiscoverOperation

@Singleton
@Requires(property = "airbyte.connector.operation", value = "discover")
@Requires(env = ["source"])
class DiscoverOperation(val config: SourceConfiguration, val metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, val airbyteStreamFactory: AirbyteStreamFactory, val outputConsumer: OutputConsumer) : Operation

Constructors

Link copied to clipboard
constructor(config: SourceConfiguration, metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, airbyteStreamFactory: AirbyteStreamFactory, outputConsumer: OutputConsumer)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open override fun execute()