MCPcopy Create free account
hub / github.com/baidu/bigflow / first

Function first

bigflow_python/python/bigflow/transforms.py:401–419  ·  view source on GitHub ↗

取出PCollection中的第一个元素 Args: pcollection (PCollection): 输入PCollection **options: 可配置选项 Returns: PObject: 取出的单个元素,以PObject给出 >>> from bigflow import transforms >>> _p = _pipeline.parallelize([3, 7, 1, 3, 2, 8]) >>> transforms.first(_p).get() 3

(pcollection, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

firstMethod · 0.80

Tested by

no test coverage detected