docs: public ComputationGraph fit(String path) {
          if (Nd4j.getExecutioner() instanceof GridExecutioner)
              ((GridExecutioner) Nd4j.getExecutioner()).flushQueue();
  
          JavaRDD<String> paths;
          try {
              paths = SparkUtils.listPaths(sc, path);
          } catch (IOException e) {
              throw new RuntimeException("Error listing paths in directory", e);
          }
  
          return fitPaths(paths);
      }