> For the complete documentation index, see [llms.txt](https://george-jen.gitbook.io/data-science-and-apache-spark/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://george-jen.gitbook.io/data-science-and-apache-spark/edgerddimpl-class.md).

# 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
This documentation is published with GitBook. GitBook is the documentation platform designed so that both humans and AI agents can read, navigate, and reason over technical content effectively. Learn more at gitbook.com.

## 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, and the optional `goal` query parameter:

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

`ask` is the immediate question: it should be specific, self-contained, and written in natural language.
`goal` is optional and describes the broader end goal you are ultimately trying to accomplish on behalf of the user. GitBook uses it to tailor the answer towards what is most useful for that goal.

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.