lucene-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbern...@apache.org
Subject svn commit: r1720849 - in /lucene/dev/trunk/solr: CHANGES.txt core/src/java/org/apache/solr/handler/StreamHandler.java solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
Date Fri, 18 Dec 2015 21:38:18 GMT
Author: jbernste
Date: Fri Dec 18 21:38:17 2015
New Revision: 1720849

URL: http://svn.apache.org/viewvc?rev=1720849&view=rev
Log:
SOLR-8443: Change /stream handler http param from stream to expr

Modified:
    lucene/dev/trunk/solr/CHANGES.txt
    lucene/dev/trunk/solr/core/src/java/org/apache/solr/handler/StreamHandler.java
    lucene/dev/trunk/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java

Modified: lucene/dev/trunk/solr/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/CHANGES.txt?rev=1720849&r1=1720848&r2=1720849&view=diff
==============================================================================
--- lucene/dev/trunk/solr/CHANGES.txt (original)
+++ lucene/dev/trunk/solr/CHANGES.txt Fri Dec 18 21:38:17 2015
@@ -196,6 +196,8 @@ Other Changes
 
 * SOLR-8426: Enable /export, /stream and /sql handlers by default and remove them from example
configs.  (shalin)
 
+* SOLR-8443: Change /stream handler http param from "stream" to "expr" (Joel Bernstein, Dennis
Gove)
+
 
 ======================= 5.5.0 =======================
 

Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/handler/StreamHandler.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/handler/StreamHandler.java?rev=1720849&r1=1720848&r2=1720849&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/handler/StreamHandler.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/handler/StreamHandler.java Fri Dec
18 21:38:17 2015
@@ -152,7 +152,7 @@ public class StreamHandler extends Reque
     TupleStream tupleStream = null;
 
     try {
-      tupleStream = this.streamFactory.constructStream(params.get("stream"));
+      tupleStream = this.streamFactory.constructStream(params.get("expr"));
     } catch (Exception e) {
       //Catch exceptions that occur while the stream is being created. This will include
streaming expression parse rules.
       SolrException.log(logger, e);

Modified: lucene/dev/trunk/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java?rev=1720849&r1=1720848&r2=1720849&view=diff
==============================================================================
--- lucene/dev/trunk/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
(original)
+++ lucene/dev/trunk/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
Fri Dec 18 21:38:17 2015
@@ -257,7 +257,7 @@ public class ParallelStream extends Clou
         params.put("distrib","false"); // We are the aggregator.
         params.put("numWorkers", workers);
         params.put("workerID", w);
-        params.put("stream", pushStream);
+        params.put("expr", pushStream);
         params.put("qt","/stream");
         Replica rep = shuffler.get(w);
         ZkCoreNodeProps zkProps = new ZkCoreNodeProps(rep);



Mime
View raw message