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

Package-level declarations

Types

Link copied to clipboard
@Singleton
class DestinationTaskLauncher(taskScopeProvider: TaskScopeProvider, catalog: DestinationCatalog, config: DestinationConfiguration, syncManager: SyncManager, inputConsumerTask: InputConsumerTask? = null, heartbeatTask: HeartbeatTask? = null, updateBatchTask: UpdateBatchStateTaskFactory, statsEmitter: StatsEmitter? = null, setupTaskFactory: SetupTaskFactory, openStreamTask: OpenStreamTask, closeStreamTaskFactory: CloseStreamTaskFactory, teardownTaskFactory: TeardownTaskFactory, loadPipeline: LoadPipeline?, updateCheckpointsTask: UpdateCheckpointsTask, failStreamTaskFactory: FailStreamTaskFactory, failSyncTaskFactory: FailSyncTaskFactory, @Named(value = "openStreamQueue") openStreamQueue: MessageQueue<DestinationStream>, @Named(value = "defaultDestinationTaskLauncherHasThrown") hasThrown: AtomicBoolean)

Governs the task workflow for the entire destination life-cycle.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
interface Task
Link copied to clipboard
@Singleton
class TaskScopeProvider(config: DestinationConfiguration)
Link copied to clipboard
sealed interface TerminalCondition