in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TransformBuilder.java [24:44]
public static Transform buildTransform(
TransformParam transformParam) throws EventBridgeException {
switch (transformParam.getForm()) {
case CONSTANT:
return buildConstantTransform(transformParam.getValue());
case JSONPATH:
return buildJsonTransform(transformParam.getValue());
case ORIGINAL:
return buildOriginalTransform();
case TEMPLATE:
return buildTemplateTransForm(transformParam.getValue(), transformParam.getTemplate());
case INSERT_FIELD:
return buildInsertFieldTransform(transformParam.getValue());
case DELETE_FIELD:
return buildDeleteFieldTransform(transformParam.getValue());
case UPDATE_FIELD:
return buildUpdateFieldTransform(transformParam.getValue());
default:
throw new EventBridgeException(TransformErrorCode.InvalidConfig);
}
}