public SinkResourceOperator getInstance(String sinkType) {
        Optional<SinkResourceOperator> instance = operatorList.stream()
                .filter(inst -> inst.accept(sinkType))
                .findFirst();
        if (!instance.isPresent()) {
            throw new BusinessException(ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT,
                    String.format(ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT.getMessage(), sinkType));
        }
        return instance.get();
    }
Get a sink resource operator instance via the given sinkType
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/SinkResourceOperatorFactory.java