You can use the parallelize method:
val data = List(
Row(1, 5, "vlr1", 10.5),
Row(2, 1, "vl3", 0.1),
Row(3, 8, "vl3", 10.0),
Row(4, 1, "vl4", 1.0))
val rdd = sc.parallelize(data)
Here I'm using a list of Rows, but you could use it with a list of
other kind of object, like this:
val x =
In scala API its there, Row.fromSeq(ARRAY), I dnt know much more
about java api
Devan M.S. | Research Associate | Cyber Security | AMRITA VISHWA
VIDYAPEETHAM | Amritapuri | Cell +919946535290 |
On Sat, Feb 28, 2015 at 1:28 PM, r7raul1...@163.com
wrote:
> import org.apache.spark.sql.catalys
