使用SparkSession在Java或Scala中创建DSEGraphFrames

import org.apache.spark.sql.SparkSession;
import com.datastax.spark.connector._
import org.graphframes._

SparkSession spark = SparkSession.builder()
                .appName("DSEGraphFramesExample")
                .master("local[*]")
                .config("spark.cassandra.connection.host", "localhost")
                .getOrCreate();

DataFrame vertices = spark.read()
                .format("org.apache.spark.sql.cassandra")
                .options(new HashMap<String, String>() {{
                    put("keyspace", "graph_keyspace");
                    put("table", "vertices");
                }})
                .load();

DataFrame edges = spark.read()
                .format("org.apache.spark.sql.cassandra")
                .options(new HashMap<String, String>() {{
                    put("keyspace", "graph_keyspace");
                    put("table", "edges");
                }})
                .load();

GraphFrame graph = GraphFrame(vertices, edges);

graph.vertices().show();
graph.edges().show();
graph.inDegrees().show();
graph.outDegrees().show();
graph.pageRank().run().vertices().show();