1

我想通过火花作业导出 DSE 图，按照 https://docs.datastax.com/en/dse/6.0/dse-dev/datastax_enterprise/graph/graphAnalytics/dseGraphFrameExport.html

所有这些在 spark-shell 中都可以正常工作，我想在 Java 中使用 DseGraphFrame 来执行此操作。不幸的是，文档中没有太多内容

我可以用以下代码打包一个罐子并做一个 spark-submit

SparkSession spark = SparkSession
        .builder()
        .appName("Datastax Java example")
        .getOrCreate();
    DseGraphFrame dseGraphFrame = DseGraphFrameBuilder.dseGraph(args[0], spark);
    DataFrameWriter dataFrameWriter = dseGraphFrame.V().df().write();
    dataFrameWriter.csv("vertices");

以上工作正常，我想做的是使用特定的遍历来过滤我导出的内容。那就是使用类似的东西

dseGraphFrame.V().hasLabel("label").df().write();

以上不起作用，因为dseGraphFrame.V().hasLabel("label")没有.df()

这是正确的做事方式吗

任何帮助，将不胜感激

4

1 回答 1

1

这个问题的一个迟到的答案，也许仍然有用：

在 Java 中，您需要先将其转换为 DseGraphTraversal。然后可以使用以下.df()方法将其转换为 DataFrame：

((DseGraphTraversal)dseGraphFrame.V().hasLabel("label")).df().write();
于 2020-03-25T17:28:57.453 回答