graphframes.lib package

Collection of utilities usable with message aggregation

class graphframes.lib.AggregateMessages[source]

Collection of utilities usable with graphframes.GraphFrame.aggregateMessages().

dst

Reference for destination column, used for specifying messages.

edge

Reference for edge column, used for specifying messages.

static getCachedDataFrame(df)[source]

Create a new cached copy of a DataFrame.

This utility method is useful for iterative DataFrame-based algorithms. See Scala documentation for more details.

WARNING: This is NOT the same as DataFrame.cache().
The original DataFrame will NOT be cached.
msg

Reference for message column, used for specifying aggregation function.

src

Reference for source column, used for specifying messages.