HI all could anyone assist pls? i am trying to flatMap a DataSet[(String, String)] and i am getting errors in Eclipse the errors are more Scala related than spark -related, but i was wondering if someone came across a similar situation
here's what i got. A DS of (String, String) , out of which i am using flatMap to get a List[Char] of for the second element in the tuple. val tplDataSet = < DataSet[(String, String)] > val expanded = tplDataSet.flatMap(tpl => tpl._2.toList, Encoders.product[(String, String)]) Eclipse complains that 'tpl' in the above function is missing parameter type.... what am i missing? or perhaps i am using the wrong approach? w/kindest regards Marco
