src/main/java/org/apache/hadoop/hdfs/server/namenode/JavaStreamQueryEngine.java
@Override // QueryEngine
  public Collection<INode> combinedFilter(
      Collection<INode> inodes, String[] filters, String[] filterOps) {
    if (filters == null || filterOps == null || filters.length == 0 || filterOps.length == 0) {
      return inodes;
    }
    long start = System.currentTimeMillis();
    try {
      return produceFilteredStream(inodes, filters, filterOps).collect(Collectors.toList());
    } finally {
      long end = System.currentTimeMillis();
      LOG.info(
          "Performing filters: {} with filterOps: {} took: {} ms.",
          Arrays.asList(filters),
          Arrays.asList(filterOps),
          (end - start));
    }
  }
/**
   * Main filter method for filtering down a set of INodes to a smaller subset.
   *
   * @param inodes the main inode set to work on
   * @param filters set of filters to use
   * @param filterOps matching length set of filter operands and operators
   * @return the filtered set of inodes
   */
Main filter method for filtering down a set of INodes to a smaller subset.
@param inodes the main inode set to work on
@param filters set of filters to use
@param filterOps matching length set of filter operands and operators
@return the filtered set of inodes
Main filter method for filtering down a set of INodes to a smaller subset . @param inodes the main inode set to work on @param filters set of filters to use @param filterOps matching length set of filter operands and operators @return the filtered set of inodes
@Override 
  public Collection<INode> combinedFilter(
      Collection<INode> inodes, String[] filters, String[] filterOps) {
    if (filters == null || filterOps == null || filters.length == 0 || filterOps.length == 0) {
      return inodes;
    }
    long start = System.currentTimeMillis();
    try {
      return produceFilteredStream(inodes, filters, filterOps).collect(Collectors.toList());
    } finally {
      long end = System.currentTimeMillis();
      LOG.info(
          "Performing filters: {} with filterOps: {} took: {} ms.",
          Arrays.asList(filters),
          Arrays.asList(filterOps),
          (end - start));
    }
  }
@ Override public Collection < INode > combinedFilter ( Collection < INode > inodes , String [ ] filters , String [ ] filterOps ) { if ( filters == null || filterOps == null || filters . length == 0 || filterOps . length == 0 ) { return inodes ; } long start = System . currentTimeMillis ( ) ; try { return produceFilteredStream ( inodes , filters , filterOps ) . collect ( Collectors . toList ( ) ) ; } finally { long end = System . currentTimeMillis ( ) ; LOG . info ( "Performing filters: {} with filterOps: {} took: {} ms." , Arrays . asList ( filters ) , Arrays . asList ( filterOps ) , ( end - start ) ) ; } }
Main filter method for filtering down a set of INodes to a smaller subset.
Main filter method for filtering down a set of INodes to a smaller subset .
// QueryEngine