bulk-cdk-core-load/io.airbyte.cdk.load.task.implementor/CloseStreamTask

CloseStreamTask

class CloseStreamTask(syncManager: SyncManager, val streamDescriptor: DestinationStream.Descriptor, taskLauncher: DestinationTaskLauncher) : Task

Constructors

Link copied to clipboard
constructor(syncManager: SyncManager, streamDescriptor: DestinationStream.Descriptor, taskLauncher: DestinationTaskLauncher)

Properties

Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()