UpdateBatchStateTask

constructor(inputQueue: QueueReader<BatchUpdate>, syncManager: SyncManager, checkpointManager: CheckpointManager, launcher: DestinationTaskLauncher)