Zip an RDD with its element indices.

Description

The ordering is first based on the partition index and then the ordering of items within each partition. So the first item in the first partition gets index 0, and the last item in the last partition receives the largest index.

Usage

zipWithIndex(x)

## S4 method for signature 'RDD'
zipWithIndex(x)

Arguments

Details

This method needs to trigger a Spark job when this RDD contains more than one partition.

Value

An RDD with zipped items.

See Also

zipWithUniqueId

Examples

## Not run: 
##D sc <- sparkR.init()
##D rdd <- parallelize(sc, list("a", "b", "c", "d", "e"), 3L)
##D collect(zipWithIndex(rdd))
##D # list(list("a", 0), list("b", 1), list("c", 2), list("d", 3), list("e", 4))
## End(Not run)