val df = MongoSpark.load(sparkSession)


val vertices =df.select("id", "flight_origin")

val edges =df.select("orig.id","dest.id","flight.dist")
val g = GraphFrame(vertices, edges)