

def apply_CombineValues(self, transform, pcoll):
    return pvalue.PCollection(pcoll.pipeline)

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineRunner.apply_CombineValues/original