Hi, I'm trying to integrate ElasticsearchSink in my pipeline. The example <https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/elasticsearch.html>shows using Anonymous class which implements ElasticsearchSinkFunction. This is passed as a constructor argument to another anonymous class which extends ElasticsearchSink.
Can I create a separate class instead of using anonymous classes? If I do so, I'll have to have index and type as class level fields. How is state maintenance done for class level fields? Do I need to mark the fields as transient, and implement CheckpointedFunction? Thanks, Jayant
