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

Method partition

bigflow_python/python/bigflow/output.py:205–218  ·  view source on GitHub ↗

对输出结果进行分组 Args: n (int): 输出结果的分组个数，具体表现为产生n个输出文件，文件内容为各组数据 partition_fn (callable): 用于指定分组方式的函数 Returns: FileBase: 返回self

(self, n=None, partition_fn=None)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 6

test_broadcastMethod · 0.45
test_output_sortMethod · 0.45
test_add_remote_fileMethod · 0.45
test_partitionMethod · 0.45
test_gzip_fileMethod · 0.45
test_add_remote_file_for_localMethod · 0.45

Calls

no outgoing calls

Tested by 6

test_broadcastMethod · 0.36
test_output_sortMethod · 0.36
test_add_remote_fileMethod · 0.36
test_partitionMethod · 0.36
test_gzip_fileMethod · 0.36
test_add_remote_file_for_localMethod · 0.36