public List < Flow > fetchFlowsWithConfig ( String cluster , String username , String batchDesc , String signature , int limit , String ... configProps ) 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 ) ) ; String configParam = "" ; if ( configProps != null && configProps . length > 0 ) { configParam = StringUtil . buildParam ( "includeConf" , configProps ) ; } String urlString = signature == null ? String . format ( "http://%s/api/v1/flow/%s/%s/%s?limit=%d&%s" , apiHostname , cluster , username , StringUtil . cleanseToken ( batchDesc ) , limit , configParam ) : String . format ( "http://%s/api/v1/flow/%s/%s/%s/%s?limit=%d&%s" , apiHostname , cluster , username , StringUtil . cleanseToken ( batchDesc ) , signature , limit , configParam ) ; return retrieveFlowsFromURL ( urlString ) ; }
Fetches a list of flows that include jobs in that flow that include the specified configuration properties