UpdateBatchStateTaskFactory

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