public class ParallelStream extends CloudSolrStream implements Expressible
CloudSolrStream.StreamOpener, CloudSolrStream.TupleWrapper
TupleStream.IgnoreException
MapWriter.EntryWriter
cloudSolrClient, collection, comp, eofTuples, fieldMappings, params, solrStreams, streamContext, tuples, zkHost
Constructor and Description |
---|
ParallelStream(StreamExpression expression,
StreamFactory factory) |
ParallelStream(String zkHost,
String collection,
String expressionString,
int workers,
StreamComparator comp) |
ParallelStream(String zkHost,
String collection,
TupleStream tupleStream,
int workers,
StreamComparator comp) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
protected void |
constructStreams() |
Tuple |
read() |
void |
setStreamContext(StreamContext streamContext) |
void |
setStreamFactory(StreamFactory streamFactory) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
_read, adjustParams, close, getEofTuples, getSlices, getStreamSort, open, setFieldMappings, setTrace
getCost, getShards, getShards, getStreamNodeId, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
public ParallelStream(String zkHost, String collection, TupleStream tupleStream, int workers, StreamComparator comp) throws IOException
IOException
public ParallelStream(String zkHost, String collection, String expressionString, int workers, StreamComparator comp) throws IOException
IOException
public ParallelStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public void setStreamFactory(StreamFactory streamFactory)
public StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
toExpression
in class CloudSolrStream
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class CloudSolrStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic 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-2021 Apache Software Foundation. All Rights Reserved.