WriteOperation

@Singleton
@Requires(property = "airbyte.connector.operation", value = "write")
class WriteOperation(taskLauncher: DestinationTaskLauncher, syncManager: SyncManager, writeOpOverride: WriteOpOverride? = null) : Operation

Write operation. Executed by the core framework when the operation is "write". Launches the core services and awaits completion.

Constructors

Link copied to clipboard
constructor(taskLauncher: DestinationTaskLauncher, syncManager: SyncManager, writeOpOverride: WriteOpOverride? = null)

Properties

Link copied to clipboard
val log: KLogger

Functions

Link copied to clipboard
open override fun execute()