common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/InsertFieldTransform.java [35:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        JsonElement jsonElement = JsonUtil.parseJsonElement(extractJsonList);
        for (JsonElement element : jsonElement.getAsJsonArray()) {
            fieldList.add(new Variable(element.getAsJsonObject()
                .getAsJsonPrimitive(TransformFieldEnum.FIELD)
                .getAsString(), element.getAsJsonObject()
                .getAsJsonPrimitive(TransformFieldEnum.VALUE)));
        }
    }

    @Override
    public Data process(Data inputData) throws EventBridgeException {
        Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(),
            new TypeToken<Map<String, Object>>() {
            }.getType());
        for (Variable v : fieldList) {
            String[] dataList = v.getName()
                .split("\\.");
            Map<String, Object> tempMap = dataMap;
            for (int i = 1; i < dataList.length - 1; i++) {
                Object temp = tempMap.get(dataList[i]);
                if (!(temp instanceof Map)) {
                    throw new EventBridgeException(TransformErrorCode.InvalidConfig);
                }
                tempMap = (Map<String, Object>) temp;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/UpdateFieldTransform.java [35:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        JsonElement jsonElement = JsonUtil.parseJsonElement(extractJsonList);
        for (JsonElement element : jsonElement.getAsJsonArray()) {
            fieldList.add(new Variable(element.getAsJsonObject()
                .getAsJsonPrimitive(TransformFieldEnum.FIELD)
                .getAsString(), element.getAsJsonObject()
                .getAsJsonPrimitive(TransformFieldEnum.VALUE)));

        }
    }

    @Override
    public Data process(Data inputData) throws EventBridgeException {
        Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(),
            new TypeToken<Map<String, Object>>() {
            }.getType());
        for (Variable v : fieldList) {
            String[] dataList = v.getName()
                .split("\\.");
            Map<String, Object> tempMap = dataMap;
            for (int i = 1; i < dataList.length - 1; i++) {
                Object temp = tempMap.get(dataList[i]);
                if (!(temp instanceof Map)) {
                    throw new EventBridgeException(TransformErrorCode.InvalidConfig);
                }
                tempMap = (Map<String, Object>) temp;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -