UpdateBatchStateTask
class UpdateBatchStateTask(inputQueue: QueueReader<BatchUpdate>, syncManager: SyncManager, checkpointManager: CheckpointManager, launcher: DestinationTaskLauncher) : Task
A long-running task that updates the state of record batches after they are processed.
Constructors
Link copied to clipboard
constructor(inputQueue: QueueReader<BatchUpdate>, syncManager: SyncManager, checkpointManager: CheckpointManager, launcher: DestinationTaskLauncher)