hub / github.com/baidu/bigflow / is_empty

Function is_empty

bigflow_python/python/bigflow/transforms.py:1135–1155 · view source on GitHub ↗

对于输入PCollection，返回其是否为空 Args: pcollection (PCollection): 输入PCollection Returns: PObject: 表示返回结果的PObject >>> from bigflow import transforms >>> a = _pipeline.parallelize([1, 2, 3, 4]) >>> transforms.is_empty(a).get() False >>> b = _pipeline.paralleliz

(pcollection)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 1

is_emptyMethod · 0.45

Tested by

no test coverage detected