Hi Fidea,
When specifying an ID, the IndexedRequest[1] can perform a complete overwrite.
If partial update is needed, the UpdateRequest[2] can be used.
@Override
public void process(
Tuple2 element, RuntimeContext ctx, RequestIndexer
indexer) {
UpdateRequest updateRequest = new Upda
Hi Jiabao & Jiadong,
Could you please share examples on how to "*update*" data using
ElasticsearchSink?
Thanks
On Mon, Jan 29, 2024 at 9:07 PM Jiabao Sun wrote:
> Hi Fidea,
>
> I found some examples in the Java documentation, and I hope they can be
> helpful.
>
> private static class TestElas
Hi Fidea,
I found some examples in the Java documentation, and I hope they can be
helpful.
private static class TestElasticSearchSinkFunction implements
ElasticsearchSinkFunction> {
public IndexRequest createIndexRequest(Tuple2 element) {
Map json = new HashMap<>();
json.pu
Hi, Fidea.
The ElasticsearchSinkFunction Class has already marked as deprecated[1],
please try to use ElasticsearchSink Class.
Hope to help you.
Best.
Jiadong.Lu
1.
https://github.com/apache/flink-connector-elasticsearch/blob/153b8fc23e14c03c4bacf2c24fbe0fee286ec6e2/flink-connector-elasticse
Hi Team,
Could you please share with me a few example codes on how to perform
"updaterequest on elasticsearch using apache flink"
I.want to use ElasticsearchSinkFunction to perform updaterequest.
Thanks
Nida Shaikh
lideafidea...@gmail.com
