private List<StreamField> parseFieldsByJson(String statement) throws JsonProcessingException {
        return objectMapper.readValue(statement, new TypeReference<List<Map<String, String>>>() {
        }).stream().map(line -> {
            String name = line.get(BATCH_PARSING_FILED_JSON_NAME_PROP);
            String type = line.get(BATCH_PARSING_FILED_JSON_TYPE_PROP);
            String desc = line.get(BATCH_PARSING_FILED_JSON_COMMENT_PROP);
            StreamField streamField = new StreamField();
            streamField.setFieldName(name);
            streamField.setFieldType(type);
            streamField.setFieldComment(desc);
            return streamField;
        }).collect(Collectors.toList());
    }
Parse fields from CSV format

@param statement CSV statement
@return List of StreamField
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java