#include <SControlQBox.h>
Inherits QBox.
Inherited by SOutputQBox, and SUnionQBox.
Most importantly these boxes have a second output where they send control messages to the runtime engine
Public Member Functions | |
void | setupImpl () throw (AuroraException) |
void | initImpl () throw (AuroraException) |
Protected Member Functions | |
TupleDescription | createControlOutputDescription () |
Creates the schema for the output stream with control messages. | |
void | emitTuple (const Tuple &src_tuple) |
Emit a tuple on the DATA_STREAM. | |
void | emitTuple (const Tuple &undo_tuple, TupleType type) |
Emit a tuple of the given type. | |
void | emitUndoRedoTuples (const Tuple &tuple) |
Emit a tuple as an UNDO and a REDO. | |
void | emitControlTuple (int stream_id, TupleType tuple_type, Timestamp tuple_data) |
Emit a control tuple on the DATA_STREAM or CONTROL_STREAM. | |
void | emitControlTuple (TupleType tuple_type, Timestamp tuple_data) |
Emit a control tuple on the CONTROL_STREAM. | |
void | notifyOutputs () |
Notify appropriate outputs about newly available tuples. | |
AURORA_DECLARE_QBOX (SControlQBox,"scontrol") | |
Protected Attributes | |
bool | _output [TWO_OUTPUTS] |
True/false indicates whether new tuples have been produced. | |
unsigned int | _output_tuple_size |
The size in bytes of DATA_STREAM output tuples. | |
unsigned int | _control_tuple_size |
Static Protected Attributes | |
const int | DATA_STREAM = 0 |
const int | CONTROL_STREAM = 1 |
const int | TWO_OUTPUTS = 2 |
|
|
|
Creates the schema for the output stream with control messages.
Reimplemented in SUnionQBox.
|
|
Emit a control tuple on the CONTROL_STREAM.
|
|
Emit a control tuple on the DATA_STREAM or CONTROL_STREAM.
|
|
Emit a tuple of the given type.
|
|
Emit a tuple on the DATA_STREAM.
|
|
Emit a tuple as an UNDO and a REDO.
|
|
Reimplemented from QBox.
Reimplemented in SOutputQBox, and SUnionQBox.
|
|
Notify appropriate outputs about newly available tuples.
|
|
Implements QBox.
Reimplemented in SOutputQBox, and SUnionQBox.
|
|
|
|
True/false indicates whether new tuples have been produced.
|
|
The size in bytes of DATA_STREAM output tuples.
|
|
|
|
|
|
|