Public Member Functions | |
void | run () |
Runs the task. Invoked by a Scheduler's event loop. | |
Public Attributes | |
AuroraNode * | _node |
string | _stream_name |
TupleQueue * | _q |
|
Runs the task. Invoked by a Scheduler's event loop.
Implements SchedulerTask.
|
|
|
|
|
|
|