下面是通過邊構造圖的一個簡單的例子：

package graphx;import java.util.ArrayList; import java.util.List;import org.apache.spark.SparkConf; import org.apache.spark.api.java.JavaRDD; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.graphx.Edge; import org.apache.spark.graphx.Graph; import org.apache.spark.storage.StorageLevel;import scala.reflect.ClassTag;public class GraphxLearning {/*** @param args*/public static void main(String[] args) {// TODO Auto-generated method stubSparkConf conf = new SparkConf().setAppName("Graphx Learning").setMaster("local");JavaSparkContext sc = new JavaSparkContext(conf);ClassTag<String> stringTag = scala.reflect.ClassTag$.MODULE$.apply(String.class);List<Edge<String>> edges = new ArrayList<>();edges.add(new Edge<String>(1L, 2L, "Friend1"));edges.add(new Edge<String>(1L, 4L, "Friend2"));edges.add(new Edge<String>(2L, 4L, "Friend3"));edges.add(new Edge<String>(3L, 1L, "Friend4"));edges.add(new Edge<String>(3L, 4L, "Friend5"));JavaRDD<Edge<String>> edgesRDD = sc.parallelize(edges);Graph<String, String> graph = Graph.fromEdges(edgesRDD.rdd(), "", StorageLevel.MEMORY_ONLY(), StorageLevel.MEMORY_ONLY(), stringTag, stringTag);List<Edge<String>> e = graph.edges().toJavaRDD().collect();System.out.println(e);}}

參考資料

[1] API 接口文檔
[2] https://www.programcreek.com/java-api-examples/index.php?api=org.apache.spark.graphx.Graph

總結

以上是生活随笔為你收集整理的【Spark】Graphx用例（Java）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。