Hi All - I'm using the classify stream expression and the results
returned are always limited to 1,000. Where do I specify the number to
return? The stream expression that I'm using looks like:
classify(model(models,id="MODEL1014",cacheMillis=5000),search(COL,df="FULL_DOCUMENT",q="Collection:(COLLECT2000)
AND DocTimestamp:[2017-08-14T04:00:00Z TO
2017-08-15T03:59:00Z]",fl="id,score",sort="id asc"),field="ClusterText")
When I read this (code snipet):
stream.open();
while (true) {
Tuple tuple = stream.read();
if (tuple.EOF) {
break;
}
Double probabilty = (Double)
tuple.fields.get("probability_d");
String docID = (String) tuple.fields.get("id");
I get back 1,000 results. Another question is if there is a way to
parallelize the classify call to other worker nodes? Thank you!
-Joe
