Call a different query pipeline/query profile from Rest Query Stage

{

"id": "1b3488b6-9279-4b9d-8e85-603320f4e62b",
"mappingRules": [
{
"path": "//response/result/doc/*[@name=\"players_s\"]/text()",
"target": "a_newfield",
"targetLocation": "Context",
"append": false,
"xml": false
}],
"debug": true,
"resultsLocation": "Context",
"resultsKey": "queryRPC",
"params": {
"uri": "extservice://query/query-pipelines/SecApp/collections/SecApp/select",
"method": "get",
"queryParams": {
"q": "${request.params.q}",
"wt": "xml"
},
"headers": {}
},
"useIncomingRequestEntity": true,
"errorHandling": "ignore",
"hasNoSideEffects": true,
"type": "query-rpc",
"skip": false,
"legacy": false,
"secretSourceStageId": "1b3488b6-9279-4b9d-8e85-603320f4e62b"
},
{
"id": "a28d3a3c-f6ff-47ca-ac3d-f91986fa0a46",
"httpMethod": "POST",
"allowFederatedSearch": false,
"preferredReplicaType": "pull",
"type": "solr-query",
"skip": false,
"responseSignalsEnabled": true,
"secretSourceStageId": "a28d3a3c-f6ff-47ca-ac3d-f91986fa0a46"
},
{
"id": "327a4b50-c6f8-4a2d-a8b8-3c864d3ba514",
"script": "function(request,response, ctx) {\n // get the existing docs\n var docs = response.getInnerResponse().getDocuments();\n //var docs = response.initialEntity.getUnderlyingObject()\n logger.info('***** docs: ' + docs);\n \n // get the new docs\n var restQueryResponse = ctx.getProperty(\"queryRPC\"); // XML formatted string\n logger.info('*****restQueryResponse:' + restQueryResponse);\n\n\n\n var extractedValues = ctx.getProperty(\"a_newfield\"); // XML formatted string\n logger.info('*****extractedValues:' + extractedValues);\n\n // get and add the new docs to the list\n getNewDocs(docs, restQueryResponse, extractedValues);\n \n // update the response with all the new docs\n response.getInnerResponse().updateDocuments(docs);\n \n logger.info('\\n\\n***** END *****' + '\\n');\n}\n\n\nfunction getNewDocs(docList, xmlDoc, extractedValues) {\n logger.info('**** xmlDoc: ' + xmlDoc);\n logger.info('**** docList: ' + docList);\n\n \n factory = javax.xml.parsers.DocumentBuilderFactory.newInstance();\n logger.info('**** factory: ' + factory);\n\n try {\n\n logger.info('**** tryblock: ');\n var builder = factory.newDocumentBuilder();\n\n logger.info('**** builder: ' + builder);\n logger.info('**** newxmlDoc: ' + xmlDoc);\n var docs = builder.parse(new java.io.StringBufferInputStream(xmlDoc));\n \n logger.info('**** newdocs: ' + docs);\n\n // Create XPathFactory object\n var xpathFactory = javax.xml.xpath.XPathFactory.newInstance();\n\n // Create XPath object\n var xpath = xpathFactory.newXPath();\n var expr = xpath.compile(\"/response/result/doc\");\n \n // Each node is a single document\n var nodes = expr.evaluate(docs, javax.xml.xpath.XPathConstants.NODESET);\n logger.info('******** nodes: ' + nodes);\n \n info('*** nodes.getLength(): ' + nodes.getLength());\n for (var i = 0; i < nodes.getLength(); i++) { \n var node = nodes.item(i);\n \n expr = xpath.compile(\"./str[@name='id']\");\n var id = expr.evaluate(node, javax.xml.xpath.XPathConstants.STRING); \n logger.info('**** id: ' + id);\n\n expr = xpath.compile(\"./str[@name='players_s']\");\n var players = expr.evaluate(node, javax.xml.xpath.XPathConstants.STRING);\n logger.info('**** players: ' + players);\n \n expr = xpath.compile(\"./str[@name='author_s']\");\n var author = expr.evaluate(node, javax.xml.xpath.XPathConstants.STRING); \n logger.info('**** author: ' + author);\n\n expr = xpath.compile(\"./str[@name='genre_s']\");\n var genre = expr.evaluate(node, javax.xml.xpath.XPathConstants.STRING);\n logger.info('**** genre: ' + genre);\n\n //expr = xpath.compile(\"./str[@name='a_newField']\");\n //var a_newField = expr.evaluate(node, javax.xml.xpath.XPathConstants.STRING);\n //logger.info('**** a_newField: ' + a_newField);\n\n // Create a new doc and add it to the docList\n var docmap = new java.util.HashMap();\n \t docmap.put(\"id\", id);\n \t docmap.put(\"players\", players);\n \t docmap.put(\"author\", author);\n \t docmap.put(\"genre\", genre);\n\n var extractedValues = extractedValues; // XML formatted string\n \n logger.info('**** tryextractedValues: ' + extractedValues);\n\n docmap.put(\"a_newField\", extractedValues);\n \n info('**** docmap: ' + docmap);\n var newDoc = new com.lucidworks.apollo.solr.response.ResponseDocument(docmap, id);\n logger.info('**** newDoc: ' + newDoc);\n\n docList.add(newDoc); \n logger.info('**** docList: ' + docList);\n } \n } catch (e) {\n e.printStackTrace();\n }\n}\n\nfunction info(msg) {\n logger.info('\\n' + msg + '\\n');\n}",
"shareState": true,
"type": "javascript-query",
"skip": false,
"secretSourceStageId": "327a4b50-c6f8-4a2d-a8b8-3c864d3ba514"
}