Home > other >  The spark of graphframe module
The spark of graphframe module

Time:10-07

# Build ` tripGraph ` GraphFrame
# This GraphFrame builds up on the are and edges -based on our trips (flights)
TripGraph=GraphFrame (tripVertices tripEdges)
Print (tripGraph)

# Build ` tripGraphPrime ` GraphFrame
# This graphframe contains a smaller subset of data to make it easier to display motifs and subgraphs (below)
Tripid tripEdgesPrime=departureDelays_geo. Select (" ", "delay", "SRC", "DST")
TripGraphPrime=GraphFrame (tripVertices tripEdgesPrime)


error
Java. Lang. NoSuchMethodError: scala. Predef $. RefArrayOps (Ljava/lang/Object) [Ljava/lang/Object;
-- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- -- --
Py4JJavaError Traceback (the most recent call last)

1 # Build ` tripGraph ` GraphFrame
2 # This GraphFrame builds up on the are and edges -based on our trips (flights)
- & gt; 3 tripGraph=GraphFrame (tripVertices tripEdges)
4 the print (tripGraph)
5

/local_disk0/spark - bed27070 FBC - 0715-4-9995-65337586 a164 ef7087e/userFiles - 9-7659-49 df - b198c/addedFile506950925074357278graphframes_0_8_0_spark3_0_s_2_12 a57f - 5770515 - a07ea. Jar/graphframes graphframe. Py in __init__ (self, v, e)
87. The format (self. DST, ", "join (olumns of e.c. with our fabrication:)))
88
---> 89 self. _jvm_graph=self. _jvm_gf_api. CreateGraph (v. _jdf, e. _jdf)
90
91 @ property

/databricks/spark/python/lib/py4j - 0.10.7 - SRC. Zip/py4j java_gateway. Py in __call__ (self, * args)
Answer=1255 self. Gateway_client. Send_command (command)
1256 return_value=https://bbs.csdn.net/topics/get_return_value (
-> 1257 answer, self gateway_client, self. Target_id, the self. The name)

CodePudding user response:

The program always go wrong
  • Related