graphscope.framework.dag_utils.to_data_sink¶

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

Dump result to fd by drivers in vineyard.

Parameters:

result (graphscope.framework.context.ResultDAGNode) – Dataframe or numpy or result hold the object id of vineyard dataframe.
fd (str) – Such as hdfs:///tmp/result_path
kwargs (dict, optional) – Storage options with respect to output storage type

Returns:

An op to dump result to fd.