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:36:54 UTC
[3/4] lucene-solr:branch_7x: 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/2a30febc
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/2a30febc
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/2a30febc
Branch: refs/heads/branch_7x
Commit: 2a30febcf9ed96d480ce0a6c9f48713d23a18bd9
Parents: c101fd4
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 20:20:32 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/2a30febc/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 ed37ce1..1c34c73 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\")");
----