Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-10747: Change the tuple field to return-value

This commit is contained in:
Joel Bernstein 2017-05-26 11:21:51 -04:00
parent 81821b29ae
commit 3e70745c79
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
solr/core/src/java/org/apache/solr/handler/StreamHandler.java
View File

@ -305,7 +305,7 @@ public class StreamHandler extends RequestHandlerBase implements SolrCoreAware,
StreamExpression streamExpression = StreamExpressionParser.parse(params.get("expr")); StreamExpression streamExpression = StreamExpressionParser.parse(params.get("expr"));
if(this.streamFactory.isEvaluator(streamExpression)) { if(this.streamFactory.isEvaluator(streamExpression)) {
StreamExpression tupleExpression = new StreamExpression("tuple"); StreamExpression tupleExpression = new StreamExpression("tuple");
tupleExpression.addParameter(new StreamExpressionNamedParameter("out", streamExpression)); tupleExpression.addParameter(new StreamExpressionNamedParameter("return-value", streamExpression));
tupleStream = this.streamFactory.constructStream(tupleExpression); tupleStream = this.streamFactory.constructStream(tupleExpression);
} else { } else {
tupleStream = this.streamFactory.constructStream(streamExpression); tupleStream = this.streamFactory.constructStream(streamExpression);

2
solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java
View File

@ -5220,7 +5220,7 @@ public class StreamExpressionTest extends SolrCloudTestCase {
solrStream.setStreamContext(context); solrStream.setStreamContext(context);
List<Tuple> tuples = getTuples(solrStream); List<Tuple> tuples = getTuples(solrStream);
assertTrue(tuples.size() == 1); assertTrue(tuples.size() == 1);
List<Number> sequence = (List<Number>)tuples.get(0).get("out"); List<Number> sequence = (List<Number>)tuples.get(0).get("return-value");
assertTrue(sequence.size() == 20); assertTrue(sequence.size() == 20);
for(int i=0; i<sequence.size(); i++) { for(int i=0; i<sequence.size(); i++) {
assertTrue(sequence.get(i).intValue() == i); assertTrue(sequence.get(i).intValue() == i);