DseGraphFrameを使用したグラフのエクスポート

DseGraphFrameを使用して、Sparkでサポートされている任意の形式にグラフをエクスポートします。

DseGraphFrameを使用して、Sparkでサポートされている任意の形式にグラフをエクスポートします。

手順

writeメソッドを使用して、頂点とエッジをSpark対応の形式にエクスポートします。

グラフをDSEFSファイル・システムのJSONファイルにエクスポートします。

scala> g.V.write.json("/tmp/v_json")
scala> g.E.write.json("/tmp/e_json")

エクスポートすると、頂点とエッジのJSONファイルを持つ2つのディレクトリーがDSEFSファイル・システムに作成されます。ローカル・ファイル・システムに対してデータのサイズが大きすぎなければ、ローカルでデータを取得することができます。

$ dse hadoop fs -cat /tmp/v_json/* > local_vertices.json $ dse hadoop fs -cat /tmp/e_json/* > local_edges.json