| add_input_path(ptr< StreamState > str) | DataPath | |
| add_output_path(ptr< StreamState > str) | DataPath | |
| checkpoint_tuples() | DataPath | |
| close_data_path(Name stream_name, MedusaID fast_dst) | DataPath | |
| DataPath(AuroraNode &node, InetAddress data_add, bool m_no_dups=false) | DataPath | |
| enqueue(ptr< StreamEvent > event) | DataPath | |
| get_recovery_method() | DataPath | |
| init() | DataPath | |
| is_input_path(ptr< StreamState > str) | DataPath | |
| is_primary() | DataPath | |
| last_input_tuples() | DataPath | |
| last_output_tuples() | DataPath | |
| m_aurora_lock | DataPath | |
| remove_input_path(ptr< StreamState > str) | DataPath | |
| remove_output_path(ptr< StreamState > str) | DataPath | |
| resume_dequeue() | DataPath | |
| send_downstream(vector< StreamEvent > &events_to_send) | DataPath | |
| set_data_path(Name stream_name, MedusaID fast_dst, bool with_history, string first_tuple) | DataPath | |
| set_primary_status(bool status) | DataPath | |
| set_recovery_method(RecoveryMethod method) | DataPath | |
| stop_enqueue() | DataPath | |
| subscribe_cb(Name stream_name, DataHandler::DHCallback cb) | DataPath | |
| suspend_dequeue() | DataPath | |
| update(StreamEvent &stream_event) | DataPath | |
| update(StreamID stream_id, string last_tuple) | DataPath | |
| update_input_path(Name stream_name, StreamDef &sd) | DataPath | |
| ~DataPath() | DataPath |
1.3.8