public List<Flow> fetchFlowsWithConfig(String cluster, String username,
      String batchDesc, String signature, int limit,
      List<String> flowResponseFilters, List<String> jobResponseFilters,
      List<String> configPropertyFields) throws IOException {
    LOG.info(String.format(
        "Fetching last %d matching jobs for cluster=%s, user.name=%s, "
            + "batch.desc=%s, pig.logical.plan.signature=%s",
        limit, cluster, username, batchDesc, signature));
    StringBuilder urlStringBuilder = buildFlowURL(cluster, username, batchDesc,
        signature, limit, flowResponseFilters, jobResponseFilters);

    if ((configPropertyFields != null) && (configPropertyFields.size() > 0)) {
      urlStringBuilder.append(AND);
      urlStringBuilder
          .append(StringUtil.buildParam("includeConf", configPropertyFields));
    }
    return retrieveFlowsFromURL(urlStringBuilder.toString());
  }
public List < Flow > fetchFlowsWithConfig ( String cluster , String username , String batchDesc , String signature , int limit , List < String > flowResponseFilters , List < String > jobResponseFilters , List < String > configPropertyFields ) throws IOException { LOG . info ( String . format ( "Fetching last %d matching jobs for cluster=%s, user.name=%s, " + "batch.desc=%s, pig.logical.plan.signature=%s" , limit , cluster , username , batchDesc , signature ) ) ; StringBuilder urlStringBuilder = buildFlowURL ( cluster , username , batchDesc , signature , limit , flowResponseFilters , jobResponseFilters ) ; if ( ( configPropertyFields != null ) && ( configPropertyFields . size ( ) > 0 ) ) { urlStringBuilder . append ( AND ) ; urlStringBuilder . append ( StringUtil . buildParam ( "includeConf" , configPropertyFields ) ) ; } return retrieveFlowsFromURL ( urlStringBuilder . toString ( ) ) ; }
Fetches a list of flows that include jobs in that flow that include the
specified flow fields and job fields specified configuration properties
@param cluster
@param username
@param batchDesc
@param signature
@param limit
@param flowResponseFilters
@param jobResponseFilters
@param configPropertyFields
@return list of flows
@throws IOException