Hello As per the OpenSearch connector documentation, OpensearchEmitter can be used to perform requests of different types i.e., IndexRequest, DeleteRequest, UpdateRequest etc.
https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/datastream/opensearch/#configuring-the-internal-bulk-processor I need to implement the CreateIndexRequest (create Index) which is supported by OpenSearch client i.e., CreateIndexRequest How I can implement the Create Index through Flink OpenSearch connector. Thanks !! // Regards Praveen Chandna
