Hello
Request you to please share, how to proceed ? I need to create Index with
custom settings (no. of shards and replicas etc.)
Thanks !!
From: Praveen Chandna via user
Sent: Wednesday, February 21, 2024 3:57 PM
To: Praveen Chandna via user
Subject: Flink - OpenSearch connector query
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
