Airbyte Kotlin Bulk CDK

0.1.92

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

Package-level declarations

Types

fun interface CheckCleaner<C : DestinationConfiguration>

fun interface CheckCleanerV2

@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

CheckOperationV2

class CheckOperationV2(val destinationChecker: DestinationCheckerV2, outputConsumer: OutputConsumer) : Operation

DestinationChecker

interface DestinationChecker<C : DestinationConfiguration>

A check operation that is run before the destination is used.

DestinationCheckerSync

class DestinationCheckerSync<C : DestinationConfiguration>(val catalog: DestinationCatalog, stdinPipe: InputStream, writeOperation: WriteOperation, cleaner: CheckCleaner<C>) : DestinationChecker<C>

DestinationCheckerSyncV2

class DestinationCheckerSyncV2(val catalog: DestinationCatalog, stdinPipe: InputStream, writeOperation: WriteOperation, cleaner: CheckCleanerV2) : DestinationCheckerV2

DestinationCheckerV2

interface DestinationCheckerV2

A check operation that is run before the destination is used.