Code Review
/
com
/
gs-lite.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Added watchlist support
[com/gs-lite.git]
/
src
/
ftacmp
/
parse_schema.h
diff --git
a/src/ftacmp/parse_schema.h
b/src/ftacmp/parse_schema.h
index
45366a5
..
763ebd5
100644
(file)
--- a/
src/ftacmp/parse_schema.h
+++ b/
src/ftacmp/parse_schema.h
@@
-316,6
+316,8
@@
struct query_list_t;
#define STREAM_SCHEMA 2
#define OPERATOR_VIEW_SCHEMA 3
#define UNPACK_FCNS_SCHEMA 4
#define STREAM_SCHEMA 2
#define OPERATOR_VIEW_SCHEMA 3
#define UNPACK_FCNS_SCHEMA 4
+#define WATCHLIST_SCHEMA 5
+
// Represent a STREAM, PROTOCOL, OPERATOR_VIEW, or UNPACK_FCN list.
// Represent a STREAM, PROTOCOL, OPERATOR_VIEW, or UNPACK_FCN list.
@@
-332,6
+334,7
@@
private:
param_list *op_properties;
std::vector<subquery_spec *> qspec_list;
param_list *selpush;
param_list *op_properties;
std::vector<subquery_spec *> qspec_list;
param_list *selpush;
+ std::vector<std::string> key_flds; // keys of a watchlist
public:
// for unpacking function group specs.
public:
// for unpacking function group specs.
@@
-418,6
+421,13
@@
public:
return op_properties->val_of(s);
};
return op_properties->val_of(s);
};
+ void set_keys(const std::vector<std::string> &kf){
+ key_flds = kf;
+ }
+ std::vector<std::string> get_keys(){
+ return key_flds;
+ }
+
// Used in generating the LFTA prefilter
std::string get_field_basetable(std::string f);
// Used in generating the LFTA prefilter
std::string get_field_basetable(std::string f);
@@
-452,6
+462,10
@@
public:
schema_type = tmp_sch;
return ret;
}
schema_type = tmp_sch;
return ret;
}
+
+ bool is_stream(){
+ return(schema_type == PROTOCOL_SCHEMA || schema_type == STREAM_SCHEMA || schema_type == OPERATOR_VIEW_SCHEMA);
+ }
};
};
@@
-555,6
+569,10
@@
public:
return(tbl_list[t]->get_schema_id());
};
return(tbl_list[t]->get_schema_id());
};
+ bool is_stream(int t){
+ return tbl_list[t]->is_stream();
+ }
+
std::string get_op_prop(int t, std::string s){
return(tbl_list[t]->get_op_prop(s));
};
std::string get_op_prop(int t, std::string s){
return(tbl_list[t]->get_op_prop(s));
};