I am trying to write an UDF that indexes data in elasticsearch after
converting it to JSON. I had 2 questions:
1. If I create a static member in UDF class is that one instance per mapper
2. Is there a method that gets called at the end of mapper method that I
can use for cleanup?
I was wondering if I should rather write a storefunc that would index the
data. Need some help here, essentially I need some way to initialize search
Client once and then at the end close it out.