public void process(Tuple2<Boolean, Row> element, RuntimeContext ctx, RequestIndexer indexer) { if (element.f0) { processUpsert(element.f1, indexer); } else { processDelete(element.f1, indexer); }}
On 16 Oct 2019, at 09:25, ouywl <[hidden email]> wrote:Hi, When I use Elasticsearch6UpsertTableSink, and It seems implements delete index. Like code: @Overridepublic 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() ouywlouywl@...签名由 网易邮箱大师 定制