public class ParallelStream extends CloudSolrStream
CloudSolrStream.StreamOpener, CloudSolrStream.TupleWrapper
cache, cloudSolrClient, collection, comp, eofTuples, params, solrStreams, streamContext, tuples, zkHost
Constructor and Description |
---|
ParallelStream(String zkHost,
String collection,
TupleStream tupleStream,
int workers,
Comparator<Tuple> comp) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
protected void |
constructStreams() |
Tuple |
read() |
void |
setStreamContext(StreamContext streamContext) |
_read, close, getEofTuples, open, setComp, setFieldMappings, setTrace
getCost
public ParallelStream(String zkHost, String collection, TupleStream tupleStream, int workers, Comparator<Tuple> comp) throws IOException
IOException
public List<TupleStream> children()
children
in class CloudSolrStream
public Tuple read() throws IOException
read
in class CloudSolrStream
IOException
public void setStreamContext(StreamContext streamContext)
setStreamContext
in class CloudSolrStream
protected void constructStreams() throws IOException
constructStreams
in class CloudSolrStream
IOException
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.