public class CloudSolrStream extends TupleStream
Modifier and Type | Class and Description |
---|---|
protected class |
CloudSolrStream.StreamOpener |
protected class |
CloudSolrStream.TupleWrapper |
Modifier and Type | Field and Description |
---|---|
protected SolrClientCache |
cache |
protected CloudSolrClient |
cloudSolrClient |
protected String |
collection |
protected Comparator<Tuple> |
comp |
protected Map<String,Tuple> |
eofTuples |
protected Map |
params |
protected List<TupleStream> |
solrStreams |
protected StreamContext |
streamContext |
protected TreeSet<CloudSolrStream.TupleWrapper> |
tuples |
protected String |
zkHost |
Modifier | Constructor and Description |
---|---|
protected |
CloudSolrStream() |
|
CloudSolrStream(String zkHost,
String collection,
Map params) |
Modifier and Type | Method and Description |
---|---|
protected Tuple |
_read() |
List<TupleStream> |
children() |
void |
close()
Closes the CloudSolrStream
|
protected void |
constructStreams() |
Map |
getEofTuples() |
void |
open()
Opens the CloudSolrStream
|
Tuple |
read() |
void |
setComp(Comparator<Tuple> comp) |
void |
setFieldMappings(Map<String,String> fieldMappings) |
void |
setStreamContext(StreamContext context) |
void |
setTrace(boolean trace) |
getCost
protected String zkHost
protected String collection
protected Map params
protected Comparator<Tuple> comp
protected transient SolrClientCache cache
protected transient CloudSolrClient cloudSolrClient
protected transient List<TupleStream> solrStreams
protected transient TreeSet<CloudSolrStream.TupleWrapper> tuples
protected transient StreamContext streamContext
public CloudSolrStream(String zkHost, String collection, Map params) throws IOException
IOException
protected CloudSolrStream()
public void setComp(Comparator<Tuple> comp)
public void setTrace(boolean trace)
public void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public void open() throws IOException
open
in class TupleStream
IOException
public Map getEofTuples()
public List<TupleStream> children()
children
in class TupleStream
protected void constructStreams() throws IOException
IOException
public void close() throws IOException
close
in class TupleStream
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
protected Tuple _read() throws IOException
IOException
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.