使用DseGraphFrame API添加边缘属性

如何解决使用DseGraphFrame API添加边缘属性

如果要添加具有属性的边作为数据框，则属性数据应采用哪种格式？我正在阅读这些docs，但它并没有解决有关属性列格式的任何问题。

例如：

Dataset<Row> edgesToAdd = sparkDataSetContainingData
            .select(
                dseGraphFrame.idColumn(lit(srcLabel),col("sourceName")).as("src"),dseGraphFrame.idColumn(lit(destLabel),col("destinationName")).as("dst"),lit(inputEdgeLabel).as("~label"),dseGraphFrame.idColumn("some_property_key",col("some_property_value")) // is this correct?
            );

    dseGraphFrame.updateEdges(edgesToAdd,true);

解决方法

那应该是正确的-您必须包含3列：src，dst和~label。前两个使用idColumn函数生成，该函数接受顶点标签和顶点ID作为参数。您可以在DataStax-Examples的{​​{3}}中看到它。

关于该主题的资源也很多：

• following example
• blog post introducing DSE GraphFrames
• blog post about best practices working with DSE GraphFrames
• presentation from Graph Day 2018在DSE Graph Analytics上