更新时间:2023-12-04 12:18:22
Pipeline
的with
语句运行管道.具体来说:
The with
statement for Pipeline
runs the pipeline. Specifically:
with beam.Pipeline(...) as p:
[...code...]
等效于:
p = beam.Pipeline(...)
[...code...]
p.run().wait_until_finish()
请参见实现.