Class ShuffleStream
- java.lang.Object
- 
- org.apache.solr.client.solrj.io.stream.TupleStream
- 
- org.apache.solr.client.solrj.io.stream.CloudSolrStream
- 
- org.apache.solr.client.solrj.io.stream.ShuffleStream
 
 
 
- 
- All Implemented Interfaces:
- Closeable,- Serializable,- AutoCloseable,- Expressible,- MapSerializable,- MapWriter,- NavigableObject
 
 public class ShuffleStream extends CloudSolrStream implements Expressible - Since:
- 6.6.0
- See Also:
- Serialized Form
 
- 
- 
Nested Class Summary- 
Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.CloudSolrStreamCloudSolrStream.StreamOpener, CloudSolrStream.TupleWrapper
 - 
Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.TupleStreamTupleStream.IgnoreException
 - 
Nested classes/interfaces inherited from interface org.apache.solr.common.MapWriterMapWriter.EntryWriter
 
- 
 - 
Field Summary- 
Fields inherited from class org.apache.solr.client.solrj.io.stream.CloudSolrStreamcloudSolrClient, collection, comp, eofTuples, fieldMappings, params, solrStreams, streamContext, tuples, zkHost
 
- 
 - 
Constructor SummaryConstructors Constructor Description ShuffleStream(StreamExpression expression, StreamFactory factory)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description ModifiableSolrParamsadjustParams(ModifiableSolrParams mParams)ExplanationtoExplanation(StreamFactory factory)Returns an explanation about the stream objectStreamExpressiontoExpression(StreamFactory factory)- 
Methods inherited from class org.apache.solr.client.solrj.io.stream.CloudSolrStream_read, children, close, constructStreams, getEofTuples, getSlices, getStreamSort, open, read, setFieldMappings, setStreamContext, setTrace
 - 
Methods inherited from class org.apache.solr.client.solrj.io.stream.TupleStreamgetCost, getShards, getStreamNodeId, writeMap
 - 
Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 - 
Methods inherited from interface org.apache.solr.common.NavigableObject_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr
 
- 
 
- 
- 
- 
Constructor Detail- 
ShuffleStreampublic ShuffleStream(StreamExpression expression, StreamFactory factory) throws IOException - Throws:
- IOException
 
 
- 
 - 
Method Detail- 
toExpressionpublic StreamExpression toExpression(StreamFactory factory) throws IOException - Specified by:
- toExpressionin interface- Expressible
- Overrides:
- toExpressionin class- CloudSolrStream
- Throws:
- IOException
 
 - 
toExplanationpublic Explanation toExplanation(StreamFactory factory) throws IOException Description copied from interface:ExpressibleReturns an explanation about the stream object- Specified by:
- toExplanationin interface- Expressible
- Overrides:
- toExplanationin class- CloudSolrStream
- Parameters:
- factory- Stream factory for this, contains information about the function name
- Returns:
- Explanation about this stream object containing explanations of any child stream objects
- Throws:
- IOException- throw on any error
 
 - 
adjustParamspublic ModifiableSolrParams adjustParams(ModifiableSolrParams mParams) - Overrides:
- adjustParamsin class- CloudSolrStream
 
 
- 
 
-