streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/hive/StreamsHiveGenerationConfig.java [41:100]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public String getSourceDirectory() {
    return sourceDirectory;
  }

  public List<String> getSourcePaths() {
    return sourcePaths;
  }

  private String sourceDirectory;
  private List<String> sourcePaths = new ArrayList<String>();
  private String targetDirectory;
  private int maxDepth = 1;

  public Set<String> getExclusions() {
    return exclusions;
  }

  public void setExclusions(Set<String> exclusions) {
    this.exclusions = exclusions;
  }

  private Set<String> exclusions = new HashSet<String>();

  public int getMaxDepth() {
    return maxDepth;
  }

  public void setSourceDirectory(String sourceDirectory) {
    this.sourceDirectory = sourceDirectory;
  }

  public void setSourcePaths(List<String> sourcePaths) {
    this.sourcePaths = sourcePaths;
  }

  public void setTargetDirectory(String targetDirectory) {
    this.targetDirectory = targetDirectory;
  }

  @Override
  public File getTargetDirectory() {
    return new File(targetDirectory);
  }

  @Override
  public Iterator<URL> getSource() {
    if (null != sourceDirectory) {
      return Collections.singleton(URLUtil.parseURL(sourceDirectory)).iterator();
    }
    List<URL> sourceUrls = new ArrayList<URL>();
    if ( sourcePaths != null && sourcePaths.size() > 0) {
      for (String source : sourcePaths) {
        sourceUrls.add(URLUtil.parseURL(source));
      }
    }
    return sourceUrls.iterator();
  }

  public void setMaxDepth(int maxDepth) {
    this.maxDepth = maxDepth;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



streams-plugins/streams-plugin-pig/src/main/java/org/apache/streams/plugins/pig/StreamsPigGenerationConfig.java [41:104]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public String getSourceDirectory() {
    return sourceDirectory;
  }

  public List<String> getSourcePaths() {
    return sourcePaths;
  }

  private String sourceDirectory;
  private List<String> sourcePaths = new ArrayList<String>();
  private String targetDirectory;
  private int maxDepth = 1;

  public Set<String> getExclusions() {
    return exclusions;
  }

  public void setExclusions(Set<String> exclusions) {
    this.exclusions = exclusions;
  }

  private Set<String> exclusions = new HashSet<String>();

  public int getMaxDepth() {
    return maxDepth;
  }

  public void setSourceDirectory(String sourceDirectory) {
    this.sourceDirectory = sourceDirectory;
  }

  public void setSourcePaths(List<String> sourcePaths) {
    this.sourcePaths = sourcePaths;
  }

  public void setTargetDirectory(String targetDirectory) {
    this.targetDirectory = targetDirectory;
  }

  @Override
  public File getTargetDirectory() {
    return new File(targetDirectory);
  }

  /**
   * get all sources.
   * @return Iterator of URL
   */
  @Override
  public Iterator<URL> getSource() {
    if (null != sourceDirectory) {
      return Collections.singleton(URLUtil.parseURL(sourceDirectory)).iterator();
    }
    List<URL> sourceUrls = new ArrayList<URL>();
    if ( sourcePaths != null && sourcePaths.size() > 0) {
      for (String source : sourcePaths) {
        sourceUrls.add(URLUtil.parseURL(source));
      }
    }
    return sourceUrls.iterator();
  }

  public void setMaxDepth(int maxDepth) {
    this.maxDepth = maxDepth;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -