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 <user@flink.apache.org>
Sent: Wednesday, February 21, 2024 3:57 PM
To: Praveen Chandna via user <user@flink.apache.org>
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

Reply via email to