About
pipe is a transformation
pipe return an RDD created by piping elements to a forked external process.
Articles Related
Snippet
pipe(command, env={})
Example with a Sc
sc = spark.sparkContext
sc.parallelize(['1', '2', '', '3']).pipe('cat').collect()
[u'1', u'2', u'', u'3']