in seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/utils/TaskOptionUtils.java [37:59]
public static <T extends TransformOptions> T getTransformOption(
Transform transform, String transformOptionsStr) throws IOException {
switch (transform) {
case FIELDMAPPER:
return convertTransformStrToOptions(
transformOptionsStr, FieldMapperTransformOptions.class);
case MULTIFIELDSPLIT:
return convertTransformStrToOptions(
transformOptionsStr, SplitTransformOptions.class);
case COPY:
return convertTransformStrToOptions(
transformOptionsStr, CopyTransformOptions.class);
case SQL:
return convertTransformStrToOptions(transformOptionsStr, SQLTransformOptions.class);
case JSONPATH:
return convertTransformStrToOptions(
transformOptionsStr, JsonPathTransformOptions.class);
case FILTERROWKIND:
case REPLACE:
default:
return null;
}
}