You are viewing a plain text version of this content. The canonical link for it is here.
Posted to solr-user@lucene.apache.org by Joe Obernberger <jo...@gmail.com> on 2017/04/18 18:33:01 UTC
SolrJ and Streaming
Hi All - any examples of using solrJ and streaming expressions
available? Like calling UpdateStream from solrJ?
Thank you!
-Joe
Re: SolrJ and Streaming
Posted by Joe Obernberger <jo...@gmail.com>.
Thank you Joel; exactly what I needed! Just had to change it to use
CloudSolrStream instead.
Much appreciated!
-Joe
On 4/18/2017 3:21 PM, Joel Bernstein wrote:
> Are you trying to send a streaming expression using SolrJ?
>
> If you are you can send the expression with the SolrStream. for example:
>
> params = new ModifiableSolrParams();
> params.set("expr", expr);
> params.set("qt", "/stream");
> SolrStream stream = new SolrStream(url, paramsLoc);
>
> try {
>
> stream.open();
>
> while(true) {
>
> Tuple tuple = stream.read();
>
> if(tuple.EOF) {
>
> break;
>
> }
>
> }
>
> } finally {
>
> stream.close();
>
> }
>
>
>
> Joel Bernstein
> http://joelsolr.blogspot.com/
>
> On Tue, Apr 18, 2017 at 2:33 PM, Joe Obernberger <
> joseph.obernberger@gmail.com> wrote:
>
>> Hi All - any examples of using solrJ and streaming expressions available?
>> Like calling UpdateStream from solrJ?
>>
>> Thank you!
>>
>> -Joe
>>
>>
Re: SolrJ and Streaming
Posted by Joel Bernstein <jo...@gmail.com>.
paramsLoc in my last email should be params
Joel Bernstein
http://joelsolr.blogspot.com/
On Tue, Apr 18, 2017 at 3:21 PM, Joel Bernstein <jo...@gmail.com> wrote:
> Are you trying to send a streaming expression using SolrJ?
>
> If you are you can send the expression with the SolrStream. for example:
>
> params = new ModifiableSolrParams();
> params.set("expr", expr);
> params.set("qt", "/stream");
> SolrStream stream = new SolrStream(url, paramsLoc);
>
> try {
>
> stream.open();
>
> while(true) {
>
> Tuple tuple = stream.read();
>
> if(tuple.EOF) {
>
> break;
>
> }
>
> }
>
> } finally {
>
> stream.close();
>
> }
>
>
>
> Joel Bernstein
> http://joelsolr.blogspot.com/
>
> On Tue, Apr 18, 2017 at 2:33 PM, Joe Obernberger <
> joseph.obernberger@gmail.com> wrote:
>
>> Hi All - any examples of using solrJ and streaming expressions
>> available? Like calling UpdateStream from solrJ?
>>
>> Thank you!
>>
>> -Joe
>>
>>
>
Re: SolrJ and Streaming
Posted by Joel Bernstein <jo...@gmail.com>.
Are you trying to send a streaming expression using SolrJ?
If you are you can send the expression with the SolrStream. for example:
params = new ModifiableSolrParams();
params.set("expr", expr);
params.set("qt", "/stream");
SolrStream stream = new SolrStream(url, paramsLoc);
try {
stream.open();
while(true) {
Tuple tuple = stream.read();
if(tuple.EOF) {
break;
}
}
} finally {
stream.close();
}
Joel Bernstein
http://joelsolr.blogspot.com/
On Tue, Apr 18, 2017 at 2:33 PM, Joe Obernberger <
joseph.obernberger@gmail.com> wrote:
> Hi All - any examples of using solrJ and streaming expressions available?
> Like calling UpdateStream from solrJ?
>
> Thank you!
>
> -Joe
>
>