Elasticsearch6UpsertTableSink how to trigger es delete index。

[ouywl]

Hi，

    When I use Elasticsearch6UpsertTableSink, and It seems implements delete index. Like code:

             @Override

public void process(Tuple2<Boolean, Row> element, RuntimeContext ctx, RequestIndexer indexer) {
   if (element.f0) {
      processUpsert(element.f1, indexer);
   } else {
      processDelete(element.f1, indexer);
   }
}

I don’t  which condition can trigger element.f0 == false and delete es index call processDelete() 

	ouywl
ou...@139.com

签名由 网易邮箱大师 定制