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