Classes | |
class | LRWaitForQBox |
struct | LRWaitForQBox::HashString |
class | LRWaitForQBox::StoredTuple |
Functions | |
AURORA_DEFINE_QBOX (LRWaitForQBox,"LRWaitFor") | |
Variables | |
BOREALIS_NAMESPACE_BEGIN | |
This box is a waitfor modification for linear road. | |
BOREALIS_NAMESPACE_END |
|
|
|
This box is a waitfor modification for linear road. One stream buffers tuples. The other stream is like a "control stream" , providing a new value for some key "n" (int). Buffered tuples are let through if one of their fields is <= n. Specifically - the control stream updates the "key field value" (n) This box always lets through tuples that have key field <= n At startup, without any control tuples, all data is buffered Data comes from input stream 0 "Control" comes from input stream 1 |
|
|