How to search ES data in java spark's mapPartitionsToPair

Elastic Stack Elasticsearch
1

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

                             xxxxxxxxxxxx
                //  I want search ES data in here

        }

})

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

2

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