Can't get this one to work and I have no idea why. JavaPairRDD<String, Iterable<String>> lel = gen.groupByKey();
JavaRDD<String> partitions = lel.mapPartitions( new FlatMapFunction<Iterator<Tuple2<String, Iterable<String>>>, String> () { public Iterable<String> call(Iterator<Tuple2<String, Iterable<String>>> it) { //return whatever } }); Netbeans complains about mapPartitions not being applicable for the used arguments. Any idea what's wrong? Thank you. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/mappartition-s-FlatMapFunction-help-tp24702.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org