#include <StreamState.h>
Public Types | |
enum | Class { INJECT, OTHER } |
Public Member Functions | |
bool | is_injected_stream () |
StreamState (Name stream_name, ptr< StreamDef > stream_def, Class clazz) | |
string | as_string () const |
string | repr () const |
ptr< StreamDef > | get_stream_def () const |
void | set_definition (ptr< StreamDef > str) |
const Name & | get_name () const |
Schema | get_schema () const |
void | incrStats (double tuples, double bytes) |
void | endStatPeriod (double delta_time_msecs) |
stream_stats | getStreamStats () |
double | n_tuples () |
Public Attributes | |
int | m_class |
vector< Subscription > | m_fast_subs |
bool | m_subscribed |
pair< MedusaID, Subscription > | m_sub |
int | m_nb_queries |
StreamBuffer | m_buffer |
double | m_tuples |
double | m_bytes |
stream_stats | m_stream_stats |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|