How to search ES data in java spark's mapPartitionsToPair

in my code
imsiRdd.mapPartitionsToPair(new PairFlatMapFunction<Iterator, String, List>() {
public Iterator<Tuple2<String, List>> call(Iterator rowIterator) throws Exception {

                //  I want search ES data in here



in my business,imsiRdd NMDS , but ES data is vary big

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.