По сути, я Java-разработчик, и теперь у меня есть возможность работать над Spark, и я прошел через основы API Spark, такие как SparkConfig, SparkContaxt, RDD, SQLContaxt, DataFrame, DataSet, и затем я смог выполнить несколько простых преобразований, используя RDD, SQL .... но когда я пытаюсь тренировать некоторые примеры графических приложений с использованием java, я не могу добиться успеха, и я прошел через множество учебных пособий по 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, IOException{

        SparkConf conf = new SparkConf().setAppName("test").setMaster("local");

        JavaSparkContext sc = new JavaSparkContext(conf);
        SQLContext sqlContext = new org.apache.spark.sql.SQLContext(sc);

        JavaRDD<Row> verRow = sc.parallelize(Arrays.asList(RowFactory.create(1,"A"),RowFactory.create(2,"B")));
        JavaRDD<Row> edgRow = sc.parallelize(Arrays.asList(RowFactory.create(1,2,"Edge")));     

        List<StructField> verFields = new ArrayList<StructField>();
        verFields.add(DataTypes.createStructField("id",DataTypes.IntegerType, true));
        verFields.add(DataTypes.createStructField("name",DataTypes.StringType, true));

        List<StructField> EdgFields = new ArrayList<StructField>();
        EdgFields.add(DataTypes.createStructField("fromId",DataTypes.IntegerType, true));
        EdgFields.add(DataTypes.createStructField("toId",DataTypes.IntegerType, true));
        EdgFields.add(DataTypes.createStructField("name",DataTypes.StringType, true));

        StructType verSchema = DataTypes.createStructType(verFields);
        StructType edgSchema = DataTypes.createStructType(EdgFields);

        DataFrame verDF = sqlContext.createDataFrame(verRow, verSchema);
        DataFrame edgDF = sqlContext.createDataFrame(edgRow, edgSchema);

        GraphFrame g = new GraphFrame(verDF,edgDF);
        g.vertices().show();
        g.edges().show();
        g.persist(StorageLevel.MEMORY_AND_DISK());
    }

}