You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by jb...@apache.org on 2017/06/05 18:36:29 UTC
[15/41] lucene-solr:branch_6x: SOLR-10731: Add tests for params
SOLR-10731: Add tests for params
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/f35be3bc
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/f35be3bc
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/f35be3bc
Branch: refs/heads/branch_6x
Commit: f35be3bc23064ad67f585d604ff4c264fa7076c1
Parents: 9966453
Author: Joel Bernstein <jb...@apache.org>
Authored: Wed May 24 07:58:35 2017 -0400
Committer: Joel Bernstein <jb...@apache.org>
Committed: Mon Jun 5 13:46:33 2017 -0400
----------------------------------------------------------------------
.../solrj/io/stream/StreamExpressionTest.java | 22 ++++++++++++++++++--
1 file changed, 20 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/f35be3bc/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java
index dc3a380..f76ed31 100644
--- a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java
+++ b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java
@@ -920,7 +920,6 @@ public class StreamExpressionTest extends SolrCloudTestCase {
}
}
-
@Test
public void testKnnStream() throws Exception {
@@ -941,7 +940,26 @@ public class StreamExpressionTest extends SolrCloudTestCase {
SolrStream solrStream = new SolrStream(jetty.getBaseUrl().toString() + "/collection1", sParams);
List<Tuple> tuples = getTuples(solrStream);
assertTrue(tuples.size() == 3);
- assertOrder(tuples,2,3,4);
+ assertOrder(tuples, 2, 3, 4);
+
+ sParams = new ModifiableSolrParams(StreamingTest.mapParams(CommonParams.QT, "/stream"));
+ sParams.add("expr", "knn(" + COLLECTIONORALIAS + ", id=\"1\", qf=\"a_t\", rows=\"4\", fl=\"id, score\", mintf=\"1\", maxdf=\"0\")");
+ solrStream = new SolrStream(jetty.getBaseUrl().toString() + "/collection1", sParams);
+ tuples = getTuples(solrStream);
+ assertTrue(tuples.size() == 0);
+
+ sParams = new ModifiableSolrParams(StreamingTest.mapParams(CommonParams.QT, "/stream"));
+ sParams.add("expr", "knn(" + COLLECTIONORALIAS + ", id=\"1\", qf=\"a_t\", rows=\"4\", fl=\"id, score\", mintf=\"1\", maxwl=\"1\")");
+ solrStream = new SolrStream(jetty.getBaseUrl().toString() + "/collection1", sParams);
+ tuples = getTuples(solrStream);
+ assertTrue(tuples.size() == 0);
+
+ sParams = new ModifiableSolrParams(StreamingTest.mapParams(CommonParams.QT, "/stream"));
+ sParams.add("expr", "knn(" + COLLECTIONORALIAS + ", id=\"1\", qf=\"a_t\", rows=\"2\", fl=\"id, score\", mintf=\"1\", minwl=\"20\")");
+ solrStream = new SolrStream(jetty.getBaseUrl().toString() + "/collection1", sParams);
+ tuples = getTuples(solrStream);
+ assertTrue(tuples.size() == 0);
+
} finally {
cache.close();
}