Hi, I would like to do multiple groupBy's in an RDD followed by a single reduce. In Java, I would need to overwrite type safety if I want this to by done multiple type (dynamic).
Is there such an example? Would the following work? JavaPairRDD<String, List<Row>> ret = all.groupBy(new GroupByFunction(groups[0])). groupBy(new GroupByFunction(groups[2])).......reduceByKey(); Regards, Ioannis _______________________________________________ This message is for information purposes only, it is not a recommendation, advice, offer or solicitation to buy or sell a product or service nor an official confirmation of any transaction. It is directed at persons who are professionals and is not intended for retail customer use. Intended for recipient only. This message is subject to the terms at: www.barclays.com/emaildisclaimer. For important disclosures, please see: www.barclays.com/salesandtradingdisclaimer regarding market commentary from Barclays Sales and/or Trading, who are active market participants; and in respect of Barclays Research, including disclosures relating to specific issuers, please see http://publicresearch.barclays.com. _______________________________________________
