public class CloudSolrStream extends TupleStream implements Expressible
Modifier and Type | Class and Description |
---|---|
protected class |
CloudSolrStream.StreamOpener |
protected class |
CloudSolrStream.TupleWrapper |
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected CloudSolrClient |
cloudSolrClient |
protected String |
collection |
protected StreamComparator |
comp |
protected Map<String,Tuple> |
eofTuples |
protected Map<String,String> |
fieldMappings |
protected ModifiableSolrParams |
params |
protected List<TupleStream> |
solrStreams |
protected StreamContext |
streamContext |
protected TreeSet<CloudSolrStream.TupleWrapper> |
tuples |
protected String |
zkHost |
Modifier | Constructor and Description |
---|---|
protected |
CloudSolrStream() |
|
CloudSolrStream(StreamExpression expression,
StreamFactory factory) |
|
CloudSolrStream(String zkHost,
String collectionName,
SolrParams params) |
Modifier and Type | Method and Description |
---|---|
protected Tuple |
_read() |
protected ModifiableSolrParams |
adjustParams(ModifiableSolrParams params) |
List<TupleStream> |
children() |
void |
close()
Closes the CloudSolrStream
|
protected void |
constructStreams() |
Map<String,Tuple> |
getEofTuples() |
static Slice[] |
getSlices(String collectionName,
ZkStateReader zkStateReader,
boolean checkAlias) |
StreamComparator |
getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
void |
open()
Opens the CloudSolrStream
|
Tuple |
read() |
void |
setFieldMappings(Map<String,String> fieldMappings) |
void |
setStreamContext(StreamContext context) |
void |
setTrace(boolean trace) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
getCost, getShards, getShards, getStreamNodeId, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
protected String zkHost
protected String collection
protected ModifiableSolrParams params
protected StreamComparator comp
protected transient CloudSolrClient cloudSolrClient
protected transient List<TupleStream> solrStreams
protected transient TreeSet<CloudSolrStream.TupleWrapper> tuples
protected transient StreamContext streamContext
protected CloudSolrStream()
public CloudSolrStream(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 wrongpublic CloudSolrStream(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 errorpublic void setTrace(boolean trace)
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
public static Slice[] getSlices(String collectionName, ZkStateReader zkStateReader, boolean checkAlias) throws IOException
IOException
protected void constructStreams() 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
protected Tuple _read() throws IOException
IOException
protected ModifiableSolrParams adjustParams(ModifiableSolrParams params)
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.