Ok but in this case where can I store the ES connection? Or all document create new ES connection inside the worker?
---------------------------------------------------------------------------------------------------------------------------------- Skype: boci13, Hangout: boci.b...@gmail.com On Wed, Jun 25, 2014 at 1:01 AM, Peng Cheng <pc...@uow.edu.au> wrote: > make sure all queries are called through class methods and wrap your query > info with a class having only simple properties (strings, collections etc). > If you can't find such wrapper you can also use SerializableWritable > wrapper > out-of-the-box, but its not recommended. (developer-api and make fat > closures that run slowly) > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/ElasticSearch-enrich-tp8209p8214.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >
