Answers for "read from elasticsearch in spark"

0

read from elasticsearch in spark

import org.apache.spark.SparkContext    
import org.apache.spark.SparkContext._

import org.elasticsearch.spark._        

...

val conf = ...
val sc = new SparkContext(conf)         

val RDD = sc.esRDD("radio/artists")
Posted by: Guest on June-02-2020
0

read from elasticsearch in spark

...
import org.elasticsearch.spark._

...
val conf = ...
val sc = new SparkContext(conf)

sc.esRDD("radio/artists", "?q=me*")
Posted by: Guest on June-02-2020

Browse Popular Code Answers by Language