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

CheckOperation

@Singleton
@Requires(property = "airbyte.connector.operation", value = "check")
@Requires(env = ["destination"])
class CheckOperation<T : ConfigurationSpecification, C : DestinationConfiguration>(val configJsonObjectSupplier: ConfigurationSpecificationSupplier<T>, val configFactory: DestinationConfigurationFactory<T, C>, val destinationChecker: DestinationChecker<C>, exceptionHandler: ExceptionHandler, outputConsumer: OutputConsumer) : Operation

Constructors

Link copied to clipboard
constructor(configJsonObjectSupplier: ConfigurationSpecificationSupplier<T>, configFactory: DestinationConfigurationFactory<T, C>, destinationChecker: DestinationChecker<C>, exceptionHandler: ExceptionHandler, outputConsumer: OutputConsumer)

Functions

Link copied to clipboard
open override fun execute()