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

Method write

bigflow_python/python/bigflow/pipeline/pipeline_base.py:280–300  ·  view source on GitHub ↗

将一个PCollection映射为外部存储数据，并在运行期写到该外部存储 Args: pcollection (PCollection): 要写出的PCollection target (Target): 表示外部存储的Target实例

(self, pcollection, target)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

bigflow_group_top_n.pyFile · 0.45
group_top_n.pyFile · 0.45
uv.pyFile · 0.45
_wrapperFunction · 0.45
_modules_to_mainFunction · 0.45
test_text_fileMethod · 0.45
test_text_file_syncMethod · 0.45
test_schema_text_fileMethod · 0.45
test_text_file_sortMethod · 0.45
test_sequence_fileMethod · 0.45
test_sequence_file_syncMethod · 0.45
test_sequence_file_invalidMethod · 0.45

Calls 4

appendMethod · 0.80
sink_byMethod · 0.80
_transform_output_formatMethod · 0.45
transform_to_nodeMethod · 0.45

Tested by 15

test_text_fileMethod · 0.36
test_text_file_syncMethod · 0.36
test_schema_text_fileMethod · 0.36
test_text_file_sortMethod · 0.36
test_sequence_fileMethod · 0.36
test_sequence_file_syncMethod · 0.36
test_sequence_file_invalidMethod · 0.36
test_sequence_file_serdeMethod · 0.36
wildcard_caseMethod · 0.36
test_commitMethod · 0.36
test_write_binary_set_by_userMethod · 0.36
test_write_binary_use_defaultMethod · 0.36