Re: Implementation of ElasticsearchSinkFunction, how to handle class level variables

Hi Jayant, Yes, you don’t have to use an anonymous class for the sink function. An actual separate class works just as fine. The class fields don’t need to be marked as transient or checkpointed, since they should just be constants that come with instantiation of the sink function, or could eve

Implementation of ElasticsearchSinkFunction, how to handle class level variables

Hi, I'm trying to integrate ElasticsearchSink in my pipeline. The example shows using Anonymous class which implements ElasticsearchSinkFunction. This is passed as a constructor argument to another anonym