The status of the DataCell is mapped onto a series of table producing SQL functions. The status of the DataCell can be queried using the table producing functions datacell.baskets(), datacell.receptors(), datacell.emitters() and datacell.queries().
sql>select * from datacell.receptors();
+-----------------+-----------+-------+----------+---------+---------+----------------------------+--------+----------+---------+
| nme | host | port | protocol | mode | status | lastseen | cycles | received | pending |
+=================+===========+=======+==========+=========+=========+============================+========+==========+=========+
| datacell.bsktin | localhost | 50500 | TCP | passive | running | 2012-08-15 19:31:28.000000 | 2 | 20 | 0 |
+-----------------+-----------+-------+----------+---------+---------+----------------------------+--------+----------+---------+
1 tuple (1.800ms)
sql>select * from datacell.emitters();
+------------------+-----------+-------+----------+--------+---------+----------------------------+--------+------+---------+
| nme | host | port | protocol | mode | status | lastsent | cycles | sent | pending |
+==================+===========+=======+==========+========+=========+============================+========+======+=========+
| datacell.bsktout | localhost | 50600 | UDP | active | running | 2012-08-15 19:31:28.000000 | 2 | 10 | 0 |
+------------------+-----------+-------+----------+--------+---------+----------------------------+--------+------+---------+
1 tuple (1.725ms)
The receptors and emitters are qualified by their communication protocal and modes. The last time they have received/sent events is shown. The events not yet handled by a continuous query are denoted as pending.
sql>select * from datacell.baskets();
+---------------------+-----------+---------+-----------+-----------+------------+------+----------------------------+--------+
| nme | threshold | winsize | winstride | timeslice | timestride | beat | seen | events |
+=====================+===========+=========+===========+===========+============+======+============================+========+
| datacell.bsktmiddle | 0 | 0 | 0 | 0 | 0 | 0 | 2012-08-15 19:31:28.000000 | 0 |
| datacell.bsktin | 0 | 0 | 0 | 0 | 0 | 0 | 2012-08-15 19:31:28.000000 | 0 |
| datacell.bsktout | 0 | 0 | 0 | 0 | 0 | 0 | 2012-08-15 19:31:28.000000 | 0 |
+---------------------+-----------+---------+-----------+-----------+------------+------+----------------------------+--------+
3 tuples (1.639ms)
sql>select * from datacell.queries();
+-----------------+---------+----------------------------+--------+--------+------+-------+---------------------------------------------------------------------------------+
| nme | status | lastrun | cycles | events | time | error | def |
+=================+=========+============================+========+========+======+=======+=================================================================================+
| datacell.pass | running | 2012-08-15 19:31:28.000000 | 6 | 20 | 613 | | insert into datacell.bsktmiddle select * from datacell.bsktin; |
| datacell.filter | running | 2012-08-15 19:31:28.000000 | 4 | 7 | 653 | | insert into datacell.bsktout select * from datacell.bsktmiddle where id %2 = 0; |
+-----------------+---------+------``---------------------+--------+--------+------+-------+----------------------------------------------------------------------------------+
The baskets have properties used by the scheduler for emptying them. The events pending are shown. The continuous queries are marked with how often they have been selected for execution, the total number of events take from all input baskets, the total execution time and their definition.
This functionality is temporarily suspended