| ack(MedusaID node, StreamID id, string last_tuple) | QueryProcessor | |
| checkpoint(vector< StreamEvent > tuples_to_checkpoint, map< StreamID, string > tuples_to_trim) | QueryProcessor | |
| choke_queries(vector< Query > queries) | QueryProcessor | |
| create_cpview(CPViewDescription view_desc, StreamDef streamdef) | QueryProcessor | |
| create_stream(StreamDef stream) | QueryProcessor | |
| get_sel() | QueryProcessor | |
| get_stats() | QueryProcessor | |
| get_subscriptions(vector< Name > streams) | QueryProcessor | |
| load_box(string file_path) | QueryProcessor | |
| NMSTL_RPC_OBJECT(QueryProcessor) | QueryProcessor | |
| pack_queries(vector< Query > queries) | QueryProcessor | |
| pack_query(Query query) | QueryProcessor | |
| QueryProcessor(string id, InetAddress data_add, int ha_interval=HA_INTERVAL, bool no_dups=false) | QueryProcessor | |
| remove_query(Query query) | QueryProcessor | |
| replace_query(vector< Name > old_queries, vector< Query > new_queries) | QueryProcessor | |
| resume_queries(vector< Query > queries) | QueryProcessor | |
| set_primary_status(bool status) | QueryProcessor | |
| set_queries_status(vector< Name > name, QueryStatus status) | QueryProcessor | |
| set_query_status(Name name, QueryStatus status) | QueryProcessor | |
| set_recovery_method(int method) | QueryProcessor | |
| set_replicas(vector< MedusaID > replicas) | QueryProcessor | |
| set_secondaries(vector< MedusaID > secondaries) | QueryProcessor | |
| setup_query(Query query) | QueryProcessor | |
| subscribe(Subscription sub, unsigned int add_or_remove) | QueryProcessor | |
| subscribe_many(vector< Subscription > sub, unsigned int add_or_remove) | QueryProcessor | |
| trim(MedusaID node, StreamID id, string last_tuple) | QueryProcessor | |
| typecheck(Query query) | QueryProcessor | |
| typecheck_and_setup(Query query) | QueryProcessor | |
| update_stream(StreamDef old_sd, StreamDef new_sd) | QueryProcessor | |
| ~QueryProcessor() | QueryProcessor | [virtual] |
