Description
StreamExpression expression = StreamExpressionParser.parse(expr); TupleStream stream = new CloudSolrStream(expression, factory); SolrClientCache solrClientCache = new SolrClientCache(); StreamContext streamContext = new StreamContext(); streamContext.setSolrClientCache(solrClientCache); stream.setStreamContext(streamContext); List<Tuple> tuples = getTuples(stream);
If we don't call streamContext.setSolrClientCache we will get an NPE. Seems like we should always have the user take solrClientCache in StreamContext's ctor ?
Attachments
Issue Links
- links to