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 |
|
|
|
1.3.8