Hi All,
I am using CloudSolrStream to get stream data for documents in Solr. I am using
/export When documents have columns of type STRING, DATE, DOUBLE, LONG. It does
not allow /export when documents have _txt column(DocValues=false). So I use
as below. I use _txt to support case insensitive search.
StreamFactory factory = new StreamFactory().withCollectionZkHost(collection,
zkHost);
StreamExpression streamExpression = StreamExpressionParser.parse("search(" +
collection + ", q=\""+filter+"\",
fl=\""+filedsCommaSeparated+"\",rows=\""+count+"\", sort=\"id asc\")");
This works, but it does not support memory management like /export. Limiting
rows by using start parameters slows down the process.
Can anyone help me how to achieve this ?
Thanks
Subhasis Patra
240-755-2601
[email protected]<mailto:[email protected]>
