@Override
    public List<EsIndexRequest> parse(
            EsSinkContext context,
            ProfileEvent event,
            TransformProcessor<String, Map<String, Object>> processor) {
        if (processor == null) {
            log.error("find no any transform processor for es sink");
            return null;
        }

        String uid = event.getUid();
        EsIdConfig idConfig = context.getIdConfig(uid);
        String indexName = idConfig.parseIndexName(event.getRawLogTime());
        byte[] bodyBytes = event.getBody();
        String strContext = new String(bodyBytes, idConfig.getCharset());
        // build
        List<Map<String, Object>> esData = processor.transform(strContext);
        return esData.stream()
                .map(data -> {
                    EsIndexRequest indexRequest = new EsIndexRequest(indexName, event);
                    indexRequest.source(data);
                    return indexRequest;
                })
                .collect(Collectors.toList());
    }
parse

@param  context
@param  event
@return
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/DefaultEvent2IndexRequestHandler.java