hub / github.com/baidu/bigflow / subtract

Method subtract

bigflow_python/python/bigflow/pcollection.py:602–618 · view source on GitHub ↗

返回不存在另一个PCollection中的元素，相当于做容器减法 Args: other (PCollection): 作为减数的PCollection Returns: PCollection: 表示减法结果的PCollection >>> a = _pipeline.parallelize([1, 2, 3, 3, 4]) >>> b = _pipeline.parallelize([1, 2, 5]) >>> a.subtract(b).ge

(self, other)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 4

subtractFunction · 0.80

substractFunction · 0.80

test_subtractMethod · 0.80

test_substract_with_duplicatedMethod · 0.80

Calls

no outgoing calls

Tested by 2

test_subtractMethod · 0.64

test_substract_with_duplicatedMethod · 0.64