e = sqlContext.createDataFrame([('a', 'b', 'friend'), ('b', 'c', 'follow'),
    ('c', 'b', 'follow')], ['src', 'dst', 'relationship'])
g = GraphFrame(v, e)
g.inDegrees.show()
g.edges.filter("relationship = 'follow'").count()
results = g.pageRank(resetProbability=0.01, maxIter=20)
results.vertices.select('id', 'pagerank').show()
Как запустить graphx с помощью Python/pyspark?