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,org.apache.solr.common.MapSerializable,org.apache.solr.common.MapWriter,org.apache.solr.common.NavigableObject,org.noggit.JSONWriter.Writable
- Since:
- 6.6.0
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.CloudSolrStream
CloudSolrStream.StreamOpener, CloudSolrStream.TupleWrapperNested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.TupleStream
TupleStream.IgnoreExceptionNested classes/interfaces inherited from interface org.apache.solr.common.MapWriter
org.apache.solr.common.MapWriter.EntryWriter -
Field Summary
Fields inherited from class org.apache.solr.client.solrj.io.stream.CloudSolrStream
collection, comp, eofTuples, fieldMappings, params, solrStreams, streamContext, tuples, zkHostFields inherited from interface org.apache.solr.common.MapWriter
EMPTY -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.solr.common.params.ModifiableSolrParamsadjustParams(org.apache.solr.common.params.ModifiableSolrParams mParams) toExplanation(StreamFactory factory) Returns an explanation about the stream objecttoExpression(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, setTraceMethods inherited from class org.apache.solr.client.solrj.io.stream.TupleStream
getCost, getShards, getShards, getStreamNodeId, writeMapMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.solr.common.MapWriter
jsonStr, toMap, writeMethods inherited from interface org.apache.solr.common.NavigableObject
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
-
Constructor Details
-
ShuffleStream
- Throws:
IOException
-
-
Method Details
-
toExpression
- Specified by:
toExpressionin interfaceExpressible- Overrides:
toExpressionin classCloudSolrStream- Throws:
IOException
-
toExplanation
Description copied from interface:ExpressibleReturns an explanation about the stream object- Specified by:
toExplanationin interfaceExpressible- Overrides:
toExplanationin classCloudSolrStream- 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
-
adjustParams
public org.apache.solr.common.params.ModifiableSolrParams adjustParams(org.apache.solr.common.params.ModifiableSolrParams mParams) - Overrides:
adjustParamsin classCloudSolrStream
-