I have data in a DataFrame loaded from a CSV file. I need to load this data into HBase using an RDD formatted in a certain way.
val rdd = sc.parallelize( Array(key1, (ColumnFamily, ColumnName1, Value1), (ColumnFamily, ColumnName2, Value2), (…), key2, (ColumnFamily, ColumnName1, Value1), (ColumnFamily, ColumnName2, Value2), (…), …) ) Can someone help me to iterate through each column in a row of data to build such an Array structure? Thanks, Ben --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org