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

UpdateBatchStateTaskFactory

@Singleton
class UpdateBatchStateTaskFactory(@Named(value = "batchStateUpdateQueue") inputQueue: QueueReader<BatchUpdate>, syncManager: SyncManager, checkpointManager: CheckpointManager)

Constructors

Link copied to clipboard
constructor(@Named(value = "batchStateUpdateQueue") inputQueue: QueueReader<BatchUpdate>, syncManager: SyncManager, checkpointManager: CheckpointManager)

Functions

Link copied to clipboard