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

Method diff

bigflow_python/python/bigflow/pcollection.py:657–673  ·  view source on GitHub ↗

返回与另一个PCollection中不相同的元素 Args: other (PCollection): 另一个PCollection Returns: PCollection: 表示结果的PCollection >>> a = _pipeline.parallelize([1, 1, 2, 3]) >>> b = _pipeline.parallelize([1, 1, 2, 2]) >>> a.diff(b).get() [(2,

(self, other)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 4

diffFunction · 0.80
test_text_fileMethod · 0.80
test_intersectionMethod · 0.80
test_add_remote_fileMethod · 0.80

Calls

no outgoing calls

Tested by 3

test_text_fileMethod · 0.64
test_intersectionMethod · 0.64
test_add_remote_fileMethod · 0.64