in supports/connect-eventbridge-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeTransformBuilder.java [33:52]
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);
}
}