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

Method count

bigflow_python/python/bigflow/pcollection.py:128–140  ·  view source on GitHub ↗

返回元素的数量，等同于 :func:`bigflow.transforms.count(self) ` Returns: PObject: 元素数量 >>> p.parallelize([1, 2, 3, 4]).count().get() 4

(self, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

countFunction · 0.45
count_distinctFunction · 0.45
avgFunction · 0.45
white_black_list.pyFile · 0.45
test_fieldsMethod · 0.45
common_scope_of_scopesMethod · 0.45
test_text_fileMethod · 0.45
test_gz_fileMethod · 0.45
is_unordered_eqFunction · 0.45
test_as_pcollectionMethod · 0.45
test_group_byMethod · 0.45
test_optional_joinMethod · 0.45

Calls

no outgoing calls

Tested by 13

test_fieldsMethod · 0.36
test_text_fileMethod · 0.36
test_gz_fileMethod · 0.36
test_as_pcollectionMethod · 0.36
test_group_byMethod · 0.36
test_optional_joinMethod · 0.36
test_schemaMethod · 0.36
test_schema_select_after_groupbyMethod · 0.36
test_schema_complex_caseMethod · 0.36
group_and_filter_then_countMethod · 0.36
test_schema_complex_case1Method · 0.36
test_take_pobjectMethod · 0.36