You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by cp...@apache.org on 2018/05/18 19:19:13 UTC
[3/4] lucene-solr:master: SOLR-12036: use DefaultStreamFactory in
Solr Ref Guide (Streaming Expressions) example
SOLR-12036: use DefaultStreamFactory in Solr Ref Guide (Streaming Expressions) example
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/0e142662
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/0e142662
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/0e142662
Branch: refs/heads/master
Commit: 0e1426627a1f2b9fc146680d6de93ba10655c4f2
Parents: 8d99d32
Author: Christine Poerschke <cp...@apache.org>
Authored: Fri May 18 19:58:56 2018 +0100
Committer: Christine Poerschke <cp...@apache.org>
Committed: Fri May 18 19:58:56 2018 +0100
----------------------------------------------------------------------
solr/solr-ref-guide/src/streaming-expressions.adoc | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0e142662/solr/solr-ref-guide/src/streaming-expressions.adoc
----------------------------------------------------------------------
diff --git a/solr/solr-ref-guide/src/streaming-expressions.adoc b/solr/solr-ref-guide/src/streaming-expressions.adoc
index ccf3bf3..3273df9 100644
--- a/solr/solr-ref-guide/src/streaming-expressions.adoc
+++ b/solr/solr-ref-guide/src/streaming-expressions.adoc
@@ -99,12 +99,7 @@ The {solr-javadocs}/solr-solrj/org/apache/solr/client/solrj/io/package-summary.h
[source,java]
----
-StreamFactory streamFactory = new StreamFactory().withCollectionZkHost("collection1", zkServer.getZkAddress())
- .withStreamFunction("search", CloudSolrStream.class)
- .withStreamFunction("unique", UniqueStream.class)
- .withStreamFunction("top", RankStream.class)
- .withStreamFunction("group", ReducerStream.class)
- .withStreamFunction("parallel", ParallelStream.class);
+StreamFactory streamFactory = new DefaultStreamFactory().withCollectionZkHost("collection1", zkServer.getZkAddress());
ParallelStream pstream = (ParallelStream)streamFactory.constructStream("parallel(collection1, group(search(collection1, q=\"*:*\", fl=\"id,a_s,a_i,a_f\", sort=\"a_s asc,a_f asc\", partitionKeys=\"a_s\"), by=\"a_s asc\"), workers=\"2\", zkHost=\""+zkHost+"\", sort=\"a_s asc\")");
----