def map(self, func, iterable, chunksize=None):
        return self.map_async(func, iterable, chunksize).get()
Adds a PValue to the pipeline's node list.
dataset/ETHPy150Open serverdensity/sd-agent/checks/libs/thread_pool.py/Pool.map--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/pipeline.py/Pipeline._add_pvalue