public StreamSourceOperator getInstance(String sourceType) {
        return sourceOperatorList.stream()
                .filter(inst -> inst.accept(sourceType))
                .findFirst()
                .orElseThrow(() -> new BusinessException(ErrorCodeEnum.SOURCE_TYPE_NOT_SUPPORT,
                        String.format(ErrorCodeEnum.SOURCE_TYPE_NOT_SUPPORT.getMessage(), sourceType)));
    }
Get a sink operator instance via the given sourceType
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceOperatorFactory.java