@Override
    public LoadNode createLoadNode(StreamNode nodeInfo, Map<String, StreamField> constantFieldMap) {
        ElasticsearchSink elasticsearchSink = (ElasticsearchSink) nodeInfo;
        Map<String, String> properties = parseProperties(elasticsearchSink.getProperties());
        List<SinkField> sinkFieldList = elasticsearchSink.getSinkFieldList();
        List<FieldInfo> fieldInfos = parseSinkFieldInfos(sinkFieldList, elasticsearchSink.getSinkName());
        List<FieldRelation> fieldRelations = parseSinkFields(sinkFieldList, constantFieldMap);
        Format format = parsingSinkMultipleFormat(elasticsearchSink.getSinkMultipleEnable(),
                elasticsearchSink.getSinkMultipleFormat());

        return new ElasticsearchLoadNode(
                elasticsearchSink.getSinkName(),
                elasticsearchSink.getSinkName(),
                fieldInfos,
                fieldRelations,
                null,
                null,
                null,
                properties,
                elasticsearchSink.getIndexName(),
                elasticsearchSink.getHosts(),
                elasticsearchSink.getUsername(),
                elasticsearchSink.getPassword(),
                elasticsearchSink.getDocumentType(),
                elasticsearchSink.getPrimaryKey(),
                elasticsearchSink.getEsVersion(),
                elasticsearchSink.getSinkMultipleEnable(),
                format,
                elasticsearchSink.getIndexPattern());
    }
The Provider for creating Elasticsearch load nodes.
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/ElasticsearchProvider.java