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

Method filter

bigflow_python/python/bigflow/pcollection.py:159–176  ·  view source on GitHub ↗

过滤元素，等同于 :func:`bigflow.transforms.filter(self, fn, *side_inputs, **options) `, Args: fn (function): 断言函数 *side_inputs: 参与运算的SideInputs **options: 可配置选项 Returns: PCollection: 过滤结果

(self, fn, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

bayes.pyFile · 0.80
filterFunction · 0.80
idl_to_strFunction · 0.80
white_black_list.pyFile · 0.80
test_entity_from_fileMethod · 0.80
filter_onFunction · 0.80
_ifFunction · 0.80
_apply_value_funcMethod · 0.80
filter_if_neither_emptyFunction · 0.80
filter_count_neFunction · 0.80
filter_if_b_is_emptyFunction · 0.80
test_normalMethod · 0.80

Calls

no outgoing calls

Tested by 7

test_entity_from_fileMethod · 0.64
_apply_value_funcMethod · 0.64
test_normalMethod · 0.64
test_side_inputMethod · 0.64
test_with_side_input_ptableMethod · 0.64
test_normalMethod · 0.64
test_side_inputMethod · 0.64