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

Method flatten_values

bigflow_python/python/bigflow/ptable.py:263–271  ·  view source on GitHub ↗

使用Value中的每个元素(value 1, value 2, ... value m),构造PCollection,等价于 ``self.extract_values()`` Returns: PCollection: 包含所有Value的PCollection

(self)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

selectFunction · 0.80
distinctFunction · 0.80
post_processMethod · 0.80
flatten_valuesFunction · 0.80
_keyMethod · 0.80
selectFunction · 0.80
test_partitionedMethod · 0.80
is_unordered_eqFunction · 0.80
test_group_byMethod · 0.80
extract_valuesFunction · 0.80

Calls

no outgoing calls

Tested by 9

test_partitionedMethod · 0.64
test_group_byMethod · 0.64
test_flattenMethod · 0.64
test_nested_flattenMethod · 0.64
test_normalMethod · 0.64
test_with_side_inputMethod · 0.64
test_cacheMethod · 0.64