gf_connected_components: Connected components

Description Usage Arguments Examples

Description

Computes the connected component membership of each vertex and returns a DataFrame of vertex information with each vertex assigned a component ID.

Usage

1
2
3
gf_connected_components(x, broadcast_threshold = 1000000L,
  algorithm = c("graphframes", "graphx"), checkpoint_interval = 2L,
  ...)

Arguments

x

An object coercable to a GraphFrame (typically, a gf_graphframe).

broadcast_threshold

Broadcast threshold in propagating component assignments.

algorithm

One of 'graphframes' or 'graphx'.

checkpoint_interval

Checkpoint interval in terms of number of iterations.

...

Optional arguments, currently not used.

Examples

1
2
3
4
5
6
7
## Not run: 
# checkpoint directory is required for gf_connected_components()
spark_set_checkpoint_dir(sc, tempdir())
g <- gf_friends(sc)
gf_connected_components(g)

## End(Not run)

graphframes documentation built on May 2, 2019, 9:14 a.m.