@Override
    public Map<String, String> parse2IdParams(StreamSinkEntity streamSink, List<String> fields,
            DataNodeInfo dataNodeInfo) {
        Map<String, String> idParams = super.parse2IdParams(streamSink, fields, dataNodeInfo);
        StringBuilder sb = new StringBuilder();
        for (String field : fields) {
            sb.append(field).append(" ");
        }
        idParams.computeIfAbsent(KEY_FIELDS, k -> sb.toString());
        return idParams;
    }
Elasticsearch sink operator, such as save or update Elasticsearch field, etc.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java