Class DaemonStream
- java.lang.Object
-
- org.apache.solr.client.solrj.io.stream.TupleStream
-
- org.apache.solr.client.solrj.io.stream.DaemonStream
-
- All Implemented Interfaces:
Closeable
,Serializable
,AutoCloseable
,Expressible
,MapSerializable
,MapWriter
,NavigableObject
public class DaemonStream extends TupleStream implements Expressible
- Since:
- 6.0.0
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.TupleStream
TupleStream.IgnoreException
-
Nested classes/interfaces inherited from interface org.apache.solr.common.MapWriter
MapWriter.EntryWriter
-
-
Constructor Summary
Constructors Constructor Description DaemonStream(StreamExpression expression, StreamFactory factory)
DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize)
DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<TupleStream>
children()
void
close()
boolean
equals(Object o)
String
getId()
Tuple
getInfo()
StreamComparator
getStreamSort()
int
hashCode()
void
init(TupleStream tupleStream, String id, long runInterval, int queueSize)
void
init(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
void
open()
Tuple
read()
int
remainingCapacity()
void
setDaemons(Map<String,DaemonStream> daemons)
void
setStreamContext(StreamContext streamContext)
void
shutdown()
Explanation
toExplanation(StreamFactory factory)
Returns an explanation about the stream objectStreamExpression
toExpression(StreamFactory factory)
-
Methods inherited from class org.apache.solr.client.solrj.io.stream.TupleStream
getCost, getShards, getShards, getStreamNodeId, writeMap
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.solr.common.NavigableObject
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
-
-
-
-
Constructor Detail
-
DaemonStream
public DaemonStream(StreamExpression expression, StreamFactory factory) throws IOException
- Throws:
IOException
-
DaemonStream
public DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
-
DaemonStream
public DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize)
-
-
Method Detail
-
toExpression
public StreamExpression toExpression(StreamFactory factory) throws IOException
- Specified by:
toExpression
in interfaceExpressible
- Throws:
IOException
-
toExplanation
public Explanation toExplanation(StreamFactory factory) throws IOException
Description copied from interface:Expressible
Returns an explanation about the stream object- Specified by:
toExplanation
in interfaceExpressible
- Specified by:
toExplanation
in classTupleStream
- 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
-
remainingCapacity
public int remainingCapacity()
-
init
public void init(TupleStream tupleStream, String id, long runInterval, int queueSize)
-
init
public void init(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
-
getId
public String getId()
-
open
public void open() throws IOException
- Specified by:
open
in classTupleStream
- Throws:
IOException
-
read
public Tuple read() throws IOException
- Specified by:
read
in classTupleStream
- Throws:
IOException
-
getStreamSort
public StreamComparator getStreamSort()
- Specified by:
getStreamSort
in classTupleStream
-
setStreamContext
public void setStreamContext(StreamContext streamContext)
- Specified by:
setStreamContext
in classTupleStream
-
shutdown
public void shutdown()
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in classTupleStream
-
children
public List<TupleStream> children()
- Specified by:
children
in classTupleStream
-
getInfo
public Tuple getInfo()
-
setDaemons
public void setDaemons(Map<String,DaemonStream> daemons)
-
-