public Map<String, ElasticsearchFieldInfo> getMappingMap(String indexName) throws Exception {
        final String url = esConfig.getOneHttpUrl() + InlongConstants.SLASH + indexName + "/_mapping";
        JsonObject result = HttpUtils.request(esConfig.getRestClient(), url, HttpMethod.GET, null, getHttpHeaders(),
                JsonObject.class);
        JsonObject mappings = result.getAsJsonObject(indexName);
        JsonObject properties = null;
        JsonObject fields = null;
        Map<String, ElasticsearchFieldInfo> fieldInfos = Maps.newHashMap();
        if (ObjectUtils.isNotEmpty(mappings)) {
            String MAPPINGS_KEY = "mappings";
            properties = mappings.getAsJsonObject(MAPPINGS_KEY);
        }
        if (ObjectUtils.isNotEmpty(properties)) {
            fields = properties.getAsJsonObject(FIELD_KEY);
        }
        if (ObjectUtils.isNotEmpty(fields)) {
            for (String key : fields.keySet()) {
                JsonObject field = fields.getAsJsonObject(key);
                if (StringUtils.isNotEmpty(key) && ObjectUtils.isNotEmpty(field)) {
                    ElasticsearchFieldInfo fieldInfo = new ElasticsearchFieldInfo();
                    if (ObjectUtils.isNotEmpty(field.get(FIELD_TYPE))) {
                        fieldInfo.setFieldType(field.get(FIELD_TYPE).getAsString());
                    }
                    if (ObjectUtils.isNotEmpty(field.get(FIELD_FORMAT))) {
                        fieldInfo.setFieldFormat(field.get(FIELD_FORMAT).getAsString());
                    }
                    fieldInfo.setFieldName(key);
                    fieldInfos.put(key, fieldInfo);
                }
            }
        }
        return fieldInfos;
    }
Get mapping map.

@param indexName elasticsearch index name
@return map of elasticsearch index mapping info
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/es/ElasticsearchApi.java