public List listTransformsForJob()

in seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/ConnectorServiceImpl.java [116:144]

• 26 lines of code
• 8 McCabe index (conditional complexity)

    public List<ConnectorInfo> listTransformsForJob(Long jobId) {
        funcPermissionCheck(SeatunnelFuncPermissionKeyConstant.CONNECTOR_DATASOURCE_TRANSFORMS, 0);
        BusinessMode businessMode =
                BusinessMode.valueOf(
                        jobDefinitionService
                                .getJobDefinitionByJobId(jobId)
                                .getJobType()
                                .toUpperCase());

        if (businessMode.equals(BusinessMode.DATA_INTEGRATION)) {

            return connectorCache.getTransform().stream()
                    .filter(
                            connectorInfo -> {
                                String pluginName =
                                        connectorInfo.getPluginIdentifier().getPluginName();
                                return pluginName.equals("FieldMapper")
                                        || pluginName.equals("FilterRowKind")
                                        || pluginName.equals("Replace")
                                        || pluginName.equals("Copy")
                                        || pluginName.equals("MultiFieldSplit")
                                        || pluginName.equals("Sql")
                                        || pluginName.equals("JsonPath");
                            })
                    .collect(Collectors.toList());
        }

        return Collections.emptyList();
    }