public class DaemonStream extends TupleStream implements Expressible
TupleStream.IgnoreExceptionMapWriter.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, writeMapclone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _sizepublic DaemonStream(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic 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 ExpressibleIOExceptionpublic Explanation toExplanation(StreamFactory factory) throws IOException
ExpressibletoExplanation in interface ExpressibletoExplanation in class TupleStreamfactory - 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 TupleStreamIOExceptionpublic Tuple read() throws IOException
read in class TupleStreamIOExceptionpublic StreamComparator getStreamSort()
getStreamSort in class TupleStreampublic void setStreamContext(StreamContext streamContext)
setStreamContext in class TupleStreampublic void shutdown()
public void close()
close in interface Closeableclose in interface AutoCloseableclose in class TupleStreampublic List<TupleStream> children()
children in class TupleStreampublic Tuple getInfo()
public void setDaemons(Map<String,DaemonStream> daemons)
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.