public class SqlStream extends TupleStream implements Expressible
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected CloudSolrClient |
cloudSolrClient |
protected String |
collection |
protected SolrParams |
params |
protected StreamContext |
streamContext |
protected TupleStream |
tupleStream |
protected String |
zkHost |
Constructor and Description |
---|
SqlStream(StreamExpression expression,
StreamFactory factory) |
SqlStream(String zkHost,
String collectionName,
SolrParams params) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close() |
protected void |
constructStream() |
StreamComparator |
getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
protected void |
init(String collectionName,
String zkHost,
SolrParams params) |
void |
open() |
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
getCost, getShards, getStreamNodeId, writeMap
protected String zkHost
protected String collection
protected SolrParams params
protected transient CloudSolrClient cloudSolrClient
protected transient TupleStream tupleStream
protected transient StreamContext streamContext
public SqlStream(String zkHost, String collectionName, SolrParams params) throws IOException
zkHost
- Zookeeper ensemble connection stringcollectionName
- Name of the collection to operate onparams
- Map<String, String> of parameter/value pairsIOException
- Something went wrong
This form does not allow specifying multiple clauses, say "fq" clauses, use the form that takes a SolrParams. Transition code can call the preferred method that takes SolrParams by calling CloudSolrStream(zkHost, collectionName, new ModifiableSolrParams(SolrParams.toMultiMap(new NamedList(Map<String, String>)));
public SqlStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class TupleStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorprotected void init(String collectionName, String zkHost, SolrParams params) throws IOException
IOException
public void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public void open() throws IOException
open
in class TupleStream
IOException
public List<TupleStream> children()
children
in class TupleStream
protected void constructStream() throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
IOException
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public Tuple read() throws IOException
read
in class TupleStream
IOException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.