【Spark】Graphx用例（Java）
生活随笔
收集整理的這篇文章主要介紹了
【Spark】Graphx用例（Java）
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
下面是通過邊構(gòu)造圖的一個(gè)簡單的例子：
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
總結(jié)
以上是生活随笔為你收集整理的【Spark】Graphx用例（Java）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 【运维】第二节 Prometheus 简
- 下一篇： java美元兑换,（Java实现） 美元