Added quantiling UDAFs

[com/gs-lite.git] / src / ftacmp / parse_partn.h

diff --git a/src/ftacmp/parse_partn.h b/src/ftacmp/parse_partn.h
index 36e92d6..ea9637f 100644 (file)
--- a/src/ftacmp/parse_partn.h
+++ b/src/ftacmp/parse_partn.h
@@ -1,78 +1,78 @@
-/* ------------------------------------------------
-Copyright 2014 AT&T Intellectual Property
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-     http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
- ------------------------------------------- */
-#ifndef _PARTN_PARSE_H_INCLUDED__
-#define _PARTN_PARSE_H_INCLUDED__
-
-#include<stdio.h>
-#include"parse_fta.h"
-#include"analyze_fta.h"
-
-/*             Interface to FTA Parser         */
-void PartnParser_setfileinput(FILE *f);
-void PartnParser_setstringinput(char *s);
-
-class partn_def_t{
-public:
-       std::string name;
-       std::string protocol;
-       std::vector<scalarexp_t *> se_list;
-       std::vector<std::string> field_list;
-
-       partn_def_t(const char *n, const char *p, se_list_t *sl){
-               name=n;
-               protocol=p;
-               se_list = sl->se_list;
-       }
-
-       int verify(table_list *schema, std::string &err_msg);
-       bool is_compatible(gb_table *gb_tbl);
-};
-
-class partn_def_list_t{
-public:
-       std::map<std::string, partn_def_t *> partn_map;
-
-       partn_def_list_t(partn_def_t *pd){
-               partn_map[pd->name] = pd;
-       }
-       partn_def_list_t *append(partn_def_t *pd){
-               if(partn_map.count(pd->name)){
-                       fprintf(stderr,"Warning, duplicate entry named %s in partition definitions, ignored.\n",pd->name.c_str());
-               }else{
-                       partn_map[pd->name] = pd;
-               }
-               return this;
-       }
-
-       partn_def_t *get_partn_def(std::string n){
-               if(partn_map.count(n))
-                       return partn_map[n];
-               return NULL;
-       }
-
-       int verify(table_list *schema, std::string &err_msg){
-         int retval=0;
-         std::map<std::string, partn_def_t *>::iterator mspi;
-               for(mspi=partn_map.begin(); mspi!=partn_map.end();++mspi){
-                       if((*mspi).second->verify(schema, err_msg))
-                               retval=1;
-               }
-               return retval;
-       }
-
-
-};
-
-#endif
+/* ------------------------------------------------\r
+Copyright 2014 AT&T Intellectual Property\r
+   Licensed under the Apache License, Version 2.0 (the "License");\r
+   you may not use this file except in compliance with the License.\r
+   You may obtain a copy of the License at\r
+\r
+     http://www.apache.org/licenses/LICENSE-2.0\r
+\r
+   Unless required by applicable law or agreed to in writing, software\r
+   distributed under the License is distributed on an "AS IS" BASIS,\r
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+   See the License for the specific language governing permissions and\r
+   limitations under the License.\r
+ ------------------------------------------- */\r
+#ifndef _PARTN_PARSE_H_INCLUDED__\r
+#define _PARTN_PARSE_H_INCLUDED__\r
+\r
+#include<stdio.h>\r
+#include"parse_fta.h"\r
+#include"analyze_fta.h"\r
+\r
+/*             Interface to FTA Parser         */\r
+void PartnParser_setfileinput(FILE *f);\r
+void PartnParser_setstringinput(char *s);\r
+\r
+class partn_def_t{\r
+public:\r
+       std::string name;\r
+       std::string protocol;\r
+       std::vector<scalarexp_t *> se_list;\r
+       std::vector<std::string> field_list;\r
+\r
+       partn_def_t(const char *n, const char *p, se_list_t *sl){\r
+               name=n;\r
+               protocol=p;\r
+               se_list = sl->se_list;\r
+       }\r
+\r
+       int verify(table_list *schema, std::string &err_msg);\r
+       bool is_compatible(gb_table *gb_tbl);\r
+};\r
+\r
+class partn_def_list_t{\r
+public:\r
+       std::map<std::string, partn_def_t *> partn_map;\r
+\r
+       partn_def_list_t(partn_def_t *pd){\r
+               partn_map[pd->name] = pd;\r
+       }\r
+       partn_def_list_t *append(partn_def_t *pd){\r
+               if(partn_map.count(pd->name)){\r
+                       fprintf(stderr,"Warning, duplicate entry named %s in partition definitions, ignored.\n",pd->name.c_str());\r
+               }else{\r
+                       partn_map[pd->name] = pd;\r
+               }\r
+               return this;\r
+       }\r
+\r
+       partn_def_t *get_partn_def(std::string n){\r
+               if(partn_map.count(n))\r
+                       return partn_map[n];\r
+               return NULL;\r
+       }\r
+\r
+       int verify(table_list *schema, std::string &err_msg){\r
+         int retval=0;\r
+         std::map<std::string, partn_def_t *>::iterator mspi;\r
+               for(mspi=partn_map.begin(); mspi!=partn_map.end();++mspi){\r
+                       if((*mspi).second->verify(schema, err_msg))\r
+                               retval=1;\r
+               }\r
+               return retval;\r
+       }\r
+\r
+\r
+};\r
+\r
+#endif\r