-
Notifications
You must be signed in to change notification settings - Fork 999
Closed
Description
When calling sc.esRDD
I need to specify all of resource, query, and config. I'd like to call the implicit rather than explicitly calling EsSpark(sc, resource, query, config)
. In spark/package.scala
I find:
def esRDD()
def esRDD(resource: String)
def esRDD(resource: String, query: String)
def esRDD(cfg: scala.collection.Map[String, String])
def esRDD(resource: String, cfg: scala.collection.Map[String, String])
but not a 3-parameter overload - which can be added as:
def esRDD(resource: String, query: String, cfg: scala.collection.Map[String, String]) =
EsSpark.esRDD(sc, resource, query, cfg)
def esJsonRDD(resource: String, query: String, cfg: scala.collection.Map[String, String]) =
EsSpark.esJsonRDD(sc, resource, query, cfg)