addDestPort(QBoxInputPort port) | Stream | |
addQueue(TupleQueue *q) | Stream | |
as_string() const | Stream | |
as_xml(SchemaRepresentation rep=FULL_SCHEMA_IF_ANONYMOUS) const | Stream | |
beginBuffering() | Stream | |
enq_iterator() | Stream | |
FULL_SCHEMA enum value | Stream | |
FULL_SCHEMA_IF_ANONYMOUS enum value | Stream | |
getCP() | Stream | |
getDestPorts() | Stream | |
getName() const | Stream | |
getNumTuplesEnqueued() const | Stream | |
getParams() const | Stream | |
getQueues() | Stream | |
getSourcePort() | Stream | |
getTupleDescription() const | Stream | |
notifyEnq() | Stream | |
removeDestPort(QBoxInputPort port) | Stream | |
removeQueue(TupleQueue *) | Stream | |
SCHEMA_NAME enum value | Stream | |
SchemaRepresentation enum name | Stream | |
setCP(ptr< CP > cp) | Stream | |
setSourcePort(QBoxOutputPort port) | Stream | |
stopBuffering() | Stream | |
Stream(string name, const TupleDescription &desc, AuroraNode &node, const Params ¶ms=Params()) | Stream | |
~Stream() | Stream |