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

Reply via email to