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.