bulk-cdk-core-extract/io.airbyte.cdk.check/CheckOperation

CheckOperation

@Singleton
@Requires(property = "airbyte.connector.operation", value = "check")
@Requires(env = ["source"])
class CheckOperation<T : ConfigurationSpecification>(val configJsonObjectSupplier: ConfigurationSpecificationSupplier<T>, val configFactory: SourceConfigurationFactory<T, out SourceConfiguration>, val metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, val outputConsumer: OutputConsumer, val exceptionHandler: ExceptionHandler) : Operation

Constructors

Link copied to clipboard
constructor(configJsonObjectSupplier: ConfigurationSpecificationSupplier<T>, configFactory: SourceConfigurationFactory<T, out SourceConfiguration>, metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, outputConsumer: OutputConsumer, exceptionHandler: ExceptionHandler)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open override fun execute()

Wraps all checks in exception handling because CHECK must always exit cleanly.