Tag: graphframes

如何使用java创建一个简单的spark graphframe？: 基本上我是一名java开发人员，现在我有机会参与Spark并且我经历了Spark api的基础知识，比如SparkConfig，SparkContaxt，RDD，SQLContaxt，DataFrame，DataSet然后我能够执行一些简单的简单转换RDD，SQL ….但是当我尝试使用java训练一些示例graphframe应用程序时，我可以成功并且我经历了很多youtube教程，论坛和stackoverflow线程但没有我没有找到任何直接建议当我尝试为GraphFrame类创建一个对象时，我实际上遇到了这个问题，我也下载了接收jar（ graphframes-0.2.0-spark2.0-s_2.11.jar ），但现在仍然面临问题我想放我的分析直到我到达的地方由于Spark的新事物我无法进一步移动所以如果有人帮助我它对所有人都非常有帮助。提前致谢。我面临的例外是构造函数GraphFrame（DataFrame，DataFrame）未定义 import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; 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.sql.DataFrame; import org.apache.spark.sql.Row; import org.apache.spark.sql.RowFactory; import org.apache.spark.sql.SQLContext; import org.apache.spark.sql.types.DataTypes; import org.apache.spark.sql.types.StructField; import org.apache.spark.sql.types.StructType; import org.apache.spark.storage.StorageLevel; import org.graphframes.GraphFrame; import com.fasterxml.jackson.core.JsonParseException; import com.fasterxml.jackson.databind.JsonMappingException; public class SparkJavaGraphFrameOne { public static void main(String[] args) throws JsonParseException, JsonMappingException, […]