public class DaemonStream extends TupleStream implements Expressible
TupleStream.IgnoreException
MapWriter.EntryWriter
Constructor and 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) |
Modifier and Type | Method and 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 object
|
StreamExpression |
toExpression(StreamFactory factory) |
getCost, getShards, getShards, getStreamNodeId, writeMap
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
public DaemonStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
public DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize)
public StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class TupleStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic int remainingCapacity()
public void init(TupleStream tupleStream, String id, long runInterval, int queueSize)
public void init(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
public String getId()
public void open() throws IOException
open
in class TupleStream
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public void setStreamContext(StreamContext streamContext)
setStreamContext
in class TupleStream
public void shutdown()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
public List<TupleStream> children()
children
in class TupleStream
public Tuple getInfo()
public void setDaemons(Map<String,DaemonStream> daemons)
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.