@Override
		public void process(Tuple2<Boolean, Row> element, RuntimeContext ctx, RequestIndexer indexer) {
			if (element.f0) {
				processUpsert(element.f1, indexer);
			} else {
				processDelete(element.f1, indexer);
			}
		}
Sink function for converting upserts into Elasticsearch {@link ActionRequest}s.
elasticsearch5-xh/elasticsearch5-xh-sink/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java