Class TopicStream
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.TopicStream
- 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.0.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
FieldsFields 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
ConstructorsConstructorDescriptionTopicStream(String zkHost, String checkpointCollection, String collection, String id, long initialCheckpoint, long checkpointEvery, org.apache.solr.common.params.SolrParams params) TopicStream(StreamExpression expression, StreamFactory factory) -
Method Summary
Modifier and TypeMethodDescriptionchildren()voidclose()Closes the CloudSolrStreamprotected voidintgetCost()voidopen()Opens the CloudSolrStreamread()voidsetStreamContext(StreamContext context) 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, adjustParams, getEofTuples, getSlices, getStreamSort, setFieldMappings, setTraceMethods inherited from class org.apache.solr.client.solrj.io.stream.TupleStream
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
-
Field Details
-
checkpointEvery
protected long checkpointEvery
-
-
Constructor Details
-
TopicStream
-
TopicStream
- 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
-
children
- Overrides:
childrenin classCloudSolrStream
-
open
Description copied from class:CloudSolrStreamOpens the CloudSolrStream- Overrides:
openin classCloudSolrStream- Throws:
IOException
-
close
Description copied from class:CloudSolrStreamCloses the CloudSolrStream- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classCloudSolrStream- Throws:
IOException
-
read
- Overrides:
readin classCloudSolrStream- Throws:
IOException
-
getCost
public int getCost()- Overrides:
getCostin classTupleStream
-
constructStreams
- Overrides:
constructStreamsin classCloudSolrStream- Throws:
IOException
-
setStreamContext
- Overrides:
setStreamContextin classCloudSolrStream
-