docs: public static DataMedia<? extends DataMediaSource> findSourceDataMedia(Pipeline pipeline, String namespace,
                                                                             String name, boolean notExistReturnNull) {
          for (DataMediaPair pair : pipeline.getPairs()) {
              if (isMatch(pair.getSource(), namespace, name)) {
                  return pair.getSource();
              }
          }
  
          if (notExistReturnNull) {
              return null;
          } else {
              throw new ConfigException("no such DataMedia , the namespace = " + namespace + " name = " + name);
          }
      }