From 0e1426627a1f2b9fc146680d6de93ba10655c4f2 Mon Sep 17 00:00:00 2001 From: Christine Poerschke Date: Fri, 18 May 2018 19:58:56 +0100 Subject: [PATCH] SOLR-12036: use DefaultStreamFactory in Solr Ref Guide (Streaming Expressions) example --- solr/solr-ref-guide/src/streaming-expressions.adoc | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/solr/solr-ref-guide/src/streaming-expressions.adoc b/solr/solr-ref-guide/src/streaming-expressions.adoc index ccf3bf3d1c0..3273df97539 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\")"); ----