EdgeRDDImpl Class
Class EdgeRDDImpl
1
Object
2
org.apache.spark.rdd.RDD<Edge<ED>>
3
org.apache.spark.graphx.EdgeRDD<ED>
4
org.apache.spark.graphx.impl.EdgeRDDImpl<ED,VD>
Copied!
All Implemented Interfaces: java.io.Serializable, Logging
1
public class EdgeRDDImpl<ED,VD> extends EdgeRDD<ED>
Copied!
Methods:
1
EdgeRDDImpl<ED,VD> cache()
2
​
3
Persists the edge partitions using targetStorageLevel, which defaults to MEMORY_ONLY.
4
​
5
void checkpoint()
6
​
7
Mark this RDD for checkpointing.
8
​
9
Edge<ED>[] collect()
10
​
11
Return an array that contains all of the elements in this RDD.
12
​
13
long count()
14
​
15
The number of edges in the RDD.
16
​
17
EdgeRDDImpl<ED,VD> filter(scala.Function1<EdgeTriplet<VD,ED>,Object> epred, scala.Function2<Object,VD,Object> vpred)
18
​
19
scala.Option<String> getCheckpointFile()
20
​
21
Gets the name of the directory to which this RDD was checkpointed.
22
​
23
StorageLevel getStorageLevel()
24
​
25
Get the RDD's current storage level, or StorageLevel.NONE if none is set.
26
​
27
<ED2,ED3> EdgeRDDImpl<ED3,VD> innerJoin(EdgeRDD<ED2> other, scala.Function4<Object,Object,ED,ED2,ED3> f, scala.reflect.ClassTag<ED2> evidence$4, scala.reflect.ClassTag<ED3> evidence$5)
28
​
29
Inner joins this EdgeRDD with another EdgeRDD, assuming both are partitioned using the same PartitionStrategy.
30
​
31
boolean isCheckpointed()
32
​
33
Return whether this RDD is checkpointed and materialized, either reliably or locally.
34
​
35
<ED2,VD2> EdgeRDDImpl<ED2,VD2> mapEdgePartitions(scala.Function2<Object,org.apache.spark.graphx.impl.EdgePartition<ED,VD>,org.apache.spark.graphx.impl.EdgePartition<ED2,VD2>> f, scala.reflect.ClassTag<ED2> evidence$6, scala.reflect.ClassTag<VD2> evidence$7)
36
​
37
<ED2> EdgeRDDImpl<ED2,VD> mapValues(scala.Function1<Edge<ED>,ED2> f, scala.reflect.ClassTag<ED2> evidence$3)
38
​
39
Map the values in an edge partitioning preserving the structure but changing the values.
40
​
41
scala.Option<Partitioner> partitioner()
42
​
43
If partitionsRDD already has a partitioner, use it.
44
​
45
RDD<scala.Tuple2<Object,org.apache.spark.graphx.impl.EdgePartition<ED,VD>>> partitionsRDD()
46
EdgeRDDImpl<ED,VD> persist(StorageLevel newLevel)
47
​
48
Persists the edge partitions at the specified storage level, ignoring any existing target storage level.
49
​
50
EdgeRDDImpl<ED,VD> reverse()
51
​
52
Reverse all the edges in this RDD.
53
​
54
EdgeRDDImpl<ED,VD> setName(String _name)
55
​
56
Assign a name to this RDD
57
​
58
StorageLevel targetStorageLevel()
59
​
60
EdgeRDDImpl<ED,VD> unpersist(boolean blocking)
61
​
62
Mark the RDD as non-persistent, and remove all blocks for it from memory and disk.
Copied!
Last modified 1yr ago
Copy link