Function window_into

bigflow_python/python/bigflow/transforms.py:486–499 · view source on GitHub ↗

利用给定的window对输入PCollection分组，返回一个表示分组结果的PTable Args: pcollection (PCollection): 输入PCollection window(Window): 输入Window Returns: PTable: 分组结果

(pcollection, window, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

nothing calls this directly

window_intoMethod · 0.80

no test coverage detected