# EdgeRDDImpl Class

Class EdgeRDDImpl

```
Object
  org.apache.spark.rdd.RDD<Edge<ED>>
    org.apache.spark.graphx.EdgeRDD<ED>
     org.apache.spark.graphx.impl.EdgeRDDImpl<ED,VD>
```

All Implemented Interfaces: java.io.Serializable, Logging

```
public class EdgeRDDImpl<ED,VD> extends EdgeRDD<ED>
```

Methods:

```
EdgeRDDImpl<ED,VD>	cache()

Persists the edge partitions using targetStorageLevel, which defaults to MEMORY_ONLY.

void	checkpoint()

Mark this RDD for checkpointing.

Edge<ED>[]	collect()

Return an array that contains all of the elements in this RDD.

long	count()

The number of edges in the RDD.

EdgeRDDImpl<ED,VD>	filter(scala.Function1<EdgeTriplet<VD,ED>,Object> epred, scala.Function2<Object,VD,Object> vpred) 

scala.Option<String>	getCheckpointFile()

Gets the name of the directory to which this RDD was checkpointed.

StorageLevel	getStorageLevel()

Get the RDD's current storage level, or StorageLevel.NONE if none is set.

<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)

Inner joins this EdgeRDD with another EdgeRDD, assuming both are partitioned using the same PartitionStrategy.

boolean	isCheckpointed()

Return whether this RDD is checkpointed and materialized, either reliably or locally.

<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) 

<ED2> EdgeRDDImpl<ED2,VD>	mapValues(scala.Function1<Edge<ED>,ED2> f, scala.reflect.ClassTag<ED2> evidence$3)

Map the values in an edge partitioning preserving the structure but changing the values.

scala.Option<Partitioner>	partitioner()

If partitionsRDD already has a partitioner, use it.

RDD<scala.Tuple2<Object,org.apache.spark.graphx.impl.EdgePartition<ED,VD>>>	partitionsRDD() 
EdgeRDDImpl<ED,VD>	persist(StorageLevel newLevel)

Persists the edge partitions at the specified storage level, ignoring any existing target storage level.

EdgeRDDImpl<ED,VD>	reverse()

Reverse all the edges in this RDD.

EdgeRDDImpl<ED,VD>	setName(String _name)

Assign a name to this RDD

StorageLevel	targetStorageLevel() 

EdgeRDDImpl<ED,VD>	unpersist(boolean blocking)

Mark the RDD as non-persistent, and remove all blocks for it from memory and disk.
```


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://george-jen.gitbook.io/data-science-and-apache-spark/edgerddimpl-class.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.