123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234 |
- /*##############################################################################
- HPCC SYSTEMS software Copyright (C) 2012 HPCC Systems®.
- 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.
- ############################################################################## */
- #include "platform.h"
- #define CHEAP_UCHAR_DEF
- #ifdef _WIN32
- typedef wchar_t UChar;
- #else
- typedef unsigned short UChar;
- #endif
- #include "eclhelper.hpp"
- #include "jmisc.hpp"
- #include "commonext.hpp"
- static const char **kindArray;
- MODULE_INIT(INIT_PRIORITY_STANDARD)
- {
- kindArray = (const char **)malloc(TAKlast * sizeof(const char *));
- memset(kindArray, 0, TAKlast * sizeof(const char *));
- kindArray[TAKnone] = "none";
- kindArray[TAKdiskwrite] = "diskwrite" ;
- kindArray[TAKsort] = "sort" ;
- kindArray[TAKdedup] = "dedup" ;
- kindArray[TAKfilter] = "filter" ;
- kindArray[TAKsplit] = "split" ;
- kindArray[TAKproject] = "project" ;
- kindArray[TAKrollup] = "rollup";
- kindArray[TAKiterate] = "iterate";
- kindArray[TAKaggregate] = "aggregate";
- kindArray[TAKhashaggregate] = "hashaggregate";
- kindArray[TAKfirstn] = "firstn";
- kindArray[TAKsample] = "sample";
- kindArray[TAKdegroup] = "degroup";
- kindArray[TAKjoin] = "join";
- kindArray[TAKhashjoin] = "hashjoin";
- kindArray[TAKlookupjoin] = "lookupjoin";
- kindArray[TAKselfjoin] = "selfjoin";
- kindArray[TAKkeyedjoin] = "keyedjoin";
- kindArray[TAKgroup] = "group";
- kindArray[TAKworkunitwrite] = "workunitwrite";
- kindArray[TAKfunnel] = "funnel";
- kindArray[TAKapply] = "apply";
- kindArray[TAKinlinetable] = "inlinetable";
- kindArray[TAKhashdistribute] = "hashdistribute";
- kindArray[TAKhashdedup] = "hashdedup";
- kindArray[TAKnormalize] = "normalize";
- kindArray[TAKremoteresult] = "remoteresult";
- kindArray[TAKpull] = "pull";
- kindArray[TAKdenormalize] = "denormalize";
- kindArray[TAKnormalizechild] = "normalizechild";
- kindArray[TAKchilddataset] = "childdataset";
- kindArray[TAKselectn] = "selectn";
- kindArray[TAKenth] = "enth";
- kindArray[TAKif] = "if";
- kindArray[TAKnull] = "null";
- kindArray[TAKdistribution] = "distribution";
- kindArray[TAKcountproject] = "countproject";
- kindArray[TAKchoosesets] = "choosesets";
- kindArray[TAKpiperead] = "piperead";
- kindArray[TAKpipewrite] = "pipewrite";
- kindArray[TAKcsvwrite] = "csvwrite";
- kindArray[TAKpipethrough] = "pipethrough";
- kindArray[TAKindexwrite] = "indexwrite";
- kindArray[TAKchoosesetsenth] = "choosesetsenth";
- kindArray[TAKchoosesetslast] = "choosesetslast";
- kindArray[TAKfetch] = "fetch";
- kindArray[TAKhashdenormalize] = "hashdenormalize";
- kindArray[TAKworkunitread] = "workunitread";
- kindArray[TAKthroughaggregate] = "throughaggregate";
- kindArray[TAKspill] = "spill";
- kindArray[TAKcase] = "case";
- kindArray[TAKlimit] = "limit";
- kindArray[TAKcsvfetch] = "csvfetch";
- kindArray[TAKxmlwrite] = "xmlwrite";
- kindArray[TAKjsonwrite] = "jsonwrite";
- kindArray[TAKparse] = "parse";
- kindArray[TAKtopn] = "topn";
- kindArray[TAKmerge] = "merge";
- kindArray[TAKxmlfetch] = "xmlfetch";
- kindArray[TAKjsonfetch] = "jsonfetch";
- kindArray[TAKxmlparse] = "xmlparse";
- kindArray[TAKkeyeddistribute] = "keyeddistribute";
- kindArray[TAKjoinlight] = "joinlight";
- kindArray[TAKalljoin] = "alljoin";
- kindArray[TAKsoap_rowdataset] = "SOAP_rowdataset";
- kindArray[TAKsoap_rowaction] = "SOAP_rowaction";
- kindArray[TAKsoap_datasetdataset] = "SOAP_datasetdataset";
- kindArray[TAKsoap_datasetaction] = "SOAP_datasetaction";
- kindArray[TAKkeydiff] = "keydiff";
- kindArray[TAKkeypatch] = "keypatch";
- kindArray[TAKkeyeddenormalize] = "keyeddenormalize";
- kindArray[TAKchilditerator] = "Child Dataset";
- kindArray[TAKdatasetresult] = "Dataset Result";
- kindArray[TAKrowresult] = "Row Result";
- kindArray[TAKchildif] = "childif";
- kindArray[TAKpartition] = "partition";
- kindArray[TAKlocalgraph] = "local graph";
- kindArray[TAKifaction] = "if action";
- kindArray[TAKsequential] = "sequential";
- kindArray[TAKparallel] = "parallel";
- kindArray[TAKemptyaction] = "emptyaction";
- kindArray[TAKskiplimit] = "skip_limit";
- kindArray[TAKdiskread] = "diskread";
- kindArray[TAKdisknormalize] = "disknormalize";
- kindArray[TAKdiskaggregate] = "diskaggregate";
- kindArray[TAKdiskcount] = "diskcount";
- kindArray[TAKdiskgroupaggregate] = "diskgroupaggregate";
- kindArray[TAKindexread] = "indexread";
- kindArray[TAKindexnormalize] = "indexnormalize";
- kindArray[TAKindexaggregate] = "indexaggregate";
- kindArray[TAKindexcount] = "indexcount";
- kindArray[TAKindexgroupaggregate] = "indexgroupaggregate";
- kindArray[TAKchildnormalize] = "childnormalize";
- kindArray[TAKchildaggregate] = "childaggregate";
- kindArray[TAKchildgroupaggregate] = "childgroupaggregate";
- kindArray[TAKchildthroughnormalize] = "childthroughnormalize";
- kindArray[TAKcsvread] = "csvread";
- kindArray[TAKxmlread] = "xmlread";
- kindArray[TAKjsonread] = "jsonread";
- kindArray[TAKlocalresultread] = "localresultread";
- kindArray[TAKlocalresultwrite] = "localresultwrite";
- kindArray[TAKcombine] = "combine";
- kindArray[TAKregroup] = "regroup";
- kindArray[TAKrollupgroup] = "rollupgroup";
- kindArray[TAKcombinegroup] = "combinegroup";
- kindArray[TAKlookupdenormalize] = "lookupdenormalize";
- kindArray[TAKalldenormalize] = "alldenormalize";
- kindArray[TAKdenormalizegroup] = "denormalizegroup";
- kindArray[TAKhashdenormalizegroup] = "hashdenormalizegroup";
- kindArray[TAKlookupdenormalizegroup] = "lookupdenormalizegroup";
- kindArray[TAKkeyeddenormalizegroup] = "keyeddenormalizegroup";
- kindArray[TAKalldenormalizegroup] = "alldenormalizegroup";
- kindArray[TAKlocalresultspill] = "localresultspill";
- kindArray[TAKsimpleaction] = "simpleaction";
- kindArray[TAKloopcount] = "loop";
- kindArray[TAKlooprow] = "loop";
- kindArray[TAKloopdataset] = "loop";
- kindArray[TAKchildcase] = "childcase";
- kindArray[TAKremotegraph] = "remote";
- kindArray[TAKlibrarycall] = "librarycall";
- kindArray[TAKlocalstreamread] = "localstreamread";
- kindArray[TAKprocess] = "process";
- kindArray[TAKgraphloop] ="graph";
- kindArray[TAKparallelgraphloop] = "graph";
- kindArray[TAKgraphloopresultread] = "graphloopread";
- kindArray[TAKgraphloopresultwrite] = "graphloopwrite";
- kindArray[TAKgrouped] = "grouped";
- kindArray[TAKsorted] = "sorted";
- kindArray[TAKdistributed] = "distributed";
- kindArray[TAKnwayjoin] = "nwayjoin";
- kindArray[TAKnwaymerge] = "nwaymerge";
- kindArray[TAKnwaymergejoin] = "nwaymergejoin";
- kindArray[TAKnwayinput] = "nwayinput";
- kindArray[TAKnwaygraphloopresultread] = "nwaygraphloopread";
- kindArray[TAKnwayselect] = "nwayselect";
- kindArray[TAKnonempty] = "nonempty";
- kindArray[TAKcreaterowlimit] = "createrow_limit";
- kindArray[TAKexistsaggregate] = "existsaggregate";
- kindArray[TAKcountaggregate] = "countaggregate";
- kindArray[TAKprefetchproject] = "prefetchproject";
- kindArray[TAKprefetchcountproject] = "prefetchcountproject";
- kindArray[TAKfiltergroup] = "filtergroup";
- kindArray[TAKmemoryspillread] = "memoryspillread";
- kindArray[TAKmemoryspillwrite] = "memoryspillwrite";
- kindArray[TAKmemoryspillsplit] = "memoryspillsplit";
- kindArray[TAKsection] = "section";
- kindArray[TAKlinkedrawiterator] = "linkedrawiterator";
- kindArray[TAKnormalizelinkedchild] = "normalizelinkedchild";
- kindArray[TAKfilterproject] = "filterproject";
- kindArray[TAKcatch] = "catch";
- kindArray[TAKskipcatch] = "skip_catch";
- kindArray[TAKcreaterowcatch] = "createrow_catch";
- kindArray[TAKsectioninput] = "sectioninput";
- kindArray[TAKindexgroupexists] = "indexgroupexists";
- kindArray[TAKindexgroupcount] = "indexgroupcount";
- kindArray[TAKhashdistributemerge] = "hashdistributemerge";
- kindArray[TAKselfjoinlight] = "selfjoinlight";
- kindArray[TAKwhen_dataset] = "when_dataset";
- kindArray[TAKhttp_rowdataset] = "http";
- kindArray[TAKstreamediterator] = "streamediterator";
- kindArray[TAKexternalsource] = "externalsource";
- kindArray[TAKexternalsink] = "externalsink";
- kindArray[TAKexternalprocess] = "externalprocess";
- kindArray[TAKwhen_action] = "when_action";
- kindArray[TAKsubsort] = "subsort";
- kindArray[TAKdictionaryworkunitwrite] = "dictionaryworkunitwrite";
- kindArray[TAKdictionaryresultwrite] = "dictionaryresultwrite";
- kindArray[TAKsmartjoin] = "smartjoin";
- kindArray[TAKsmartdenormalize] = "smartdenormalize";
- kindArray[TAKsmartdenormalizegroup] = "smartdenormalizegroup";
- kindArray[TAKselfdenormalize] = "selfdenormalize";
- kindArray[TAKselfdenormalizegroup] = "selfdenormalizegroup";
- kindArray[TAKspillread] = "spillread" ;
- kindArray[TAKspillwrite] = "spillwrite" ;
- //Non standard
- kindArray[TAKsubgraph] = "subgraph";
- return true;
- }
- MODULE_EXIT()
- {
- free(kindArray);
- }
- const char *activityKindStr(ThorActivityKind kind)
- {
- const char *ret = kind<TAKlast?kindArray[kind]:NULL;
- if (ret) return ret;
- static char num[32];
- itoa(kind,num,10);
- return num;
- }
|