Class VertexRDDImpl<VD>
1
Object
2
org.apache.spark.rdd.RDD<scala.Tuple2<Object,VD>>
3
org.apache.spark.graphx.VertexRDD<VD>
4
org.apache.spark.graphx.impl.VertexRDDImpl<VD>
5
​
6
All Implemented Interfaces:
7
java.io.Serializable, Logging
Copied!
Methods:
1
<VD2> VertexRDD<VD2> aggregateUsingIndex(RDD<scala.Tuple2<Object,VD2>> messages, scala.Function2<VD2,VD2,VD2> reduceFunc, scala.reflect.ClassTag<VD2> evidence$12)
2
​
3
Aggregates vertices in messages that have the same ids using reduceFunc, returning a
4
VertexRDD co-indexed with this.
5
VertexRDDImpl<VD> cache()
6
​
7
Persists the vertex partitions at targetStorageLevel, which defaults to MEMORY_ONLY.
8
​
9
void checkpoint()
10
​
11
Mark this RDD for checkpointing.
12
​
13
long count()
14
​
15
The number of vertices in the RDD.
16
​
17
VertexRDD<VD> diff(RDD<scala.Tuple2<Object,VD>> other)
18
​
19
For each vertex present in both this and other, diff returns only those vertices with differing values; for values that are different, keeps the values from other.
20
​
21
VertexRDD<VD> diff(VertexRDD<VD> other)
22
​
23
For each vertex present in both this and other, diff returns only those vertices with differing values; for values that are different, keeps the values from other.
24
​
25
scala.Option<String> getCheckpointFile()
26
​
27
Gets the name of the directory to which this RDD was checkpointed.
28
​
29
StorageLevel getStorageLevel()
30
​
31
Get the RDD's current storage level, or StorageLevel.NONE if none is set.
32
​
33
<U,VD2> VertexRDD<VD2> innerJoin(RDD<scala.Tuple2<Object,U>> other, scala.Function3<Object,VD,U,VD2> f, scala.reflect.ClassTag<U> evidence$10, scala.reflect.ClassTag<VD2> evidence$11)
34
​
35
Inner joins this VertexRDD with an RDD containing vertex attribute pairs.
36
​
37
<U,VD2> VertexRDD<VD2> innerZipJoin(VertexRDD<U> other, scala.Function3<Object,VD,U,VD2> f, scala.reflect.ClassTag<U> evidence$8, scala.reflect.ClassTag<VD2> evidence$9)
38
​
39
Efficiently inner joins this VertexRDD with another VertexRDD sharing the same index.
40
​
41
boolean isCheckpointed()
42
​
43
Return whether this RDD is checkpointed and materialized, either reliably or locally.
44
​
45
<VD2,VD3> VertexRDD<VD3> leftJoin(RDD<scala.Tuple2<Object,VD2>> other, scala.Function3<Object,VD,scala.Option<VD2>,VD3> f, scala.reflect.ClassTag<VD2> evidence$6, scala.reflect.ClassTag<VD3> evidence$7)
46
​
47
Left joins this VertexRDD with an RDD containing vertex attribute pairs.
48
​
49
<VD2,VD3> VertexRDD<VD3> leftZipJoin(VertexRDD<VD2> other, scala.Function3<Object,VD,scala.Option<VD2>,VD3> f, scala.reflect.ClassTag<VD2> evidence$4, scala.reflect.ClassTag<VD3> evidence$5)
50
​
51
Left joins this RDD with another VertexRDD with the same index.
52
​
53
<VD2> VertexRDD<VD2> mapValues(scala.Function1<VD,VD2> f, scala.reflect.ClassTag<VD2> evidence$2)
54
​
55
Maps each vertex attribute, preserving the index.
56
​
57
<VD2> VertexRDD<VD2> mapValues(scala.Function2<Object,VD,VD2> f, scala.reflect.ClassTag<VD2> evidence$3)
58
​
59
Maps each vertex attribute, additionally supplying the vertex ID.
60
​
61
VertexRDD<VD> minus(RDD<scala.Tuple2<Object,VD>> other)
62
​
63
For each VertexId present in both this and other, minus will act as a set difference operation returning only those unique VertexId's present in this.
64
​
65
VertexRDD<VD> minus(VertexRDD<VD> other)
66
​
67
For each VertexId present in both this and other, minus will act as a set difference operation returning only those unique VertexId's present in this.
68
​
69
scala.Option<Partitioner> partitioner()
70
​
71
Optionally overridden by subclasses to specify how they are partitioned.
72
​
73
RDD<org.apache.spark.graphx.impl.ShippableVertexPartition<VD>> partitionsRDD()
74
​
75
VertexRDDImpl<VD> persist(StorageLevel newLevel)
76
​
77
Persists the vertex partitions at the specified storage level, ignoring any existing target storage level.
78
​
79
VertexRDD<VD> reindex()
80
​
81
Construct a new VertexRDD that is indexed by only the visible vertices.
82
​
83
VertexRDD<VD> reverseRoutingTables()
Copied!
Last modified 1yr ago
Copy link