graphscope.framework.dag_utils.to_data_sink¶

graphscope.framework.dag_utils.to_data_sink(result, fd, storage_options=None, write_options=None, **kwargs)[源代码]¶

通过vineyard中的驱动程序将结果转储到fd。

Parameters:

result (graphscope.framework.context.ResultDAGNode) – 数据框或numpy数组或结果，持有vineyard数据框的对象ID。
fd (str) – 例如 hdfs:///tmp/result_path
kwargs (dict, optional) – 关于输出存储类型的存储选项

Returns:

一个将结果转储到fd的操作。