Sestavení clastru

/* Target table/view(s) */
%let _OUTPUT = L2_spds.PREDPOJ_RIZ;
%let _OUTPUT1 = L2_spds.PREDPOJ_RIZ;

/* Options */
%let etls_filter = %nrquote(PREDPOJ_RIZ);
%let etls_maxslots = %nrquote(2);

Toto je náhled článku : Cluster. Přečtěte si celý příspěvek (375 words, čas na čtení článku 1:30 mins)

{"id":56,"date":"2009-10-29T10:21:16","date_gmt":"2009-10-29T08:21:16","guid":{"rendered":"http:\/\/www.mstefl.com\/wordpress\/?p=56"},"modified":"2009-10-29T10:24:44","modified_gmt":"2009-10-29T08:24:44","slug":"cluster","status":"publish","type":"post","link":"https:\/\/www.steflovi.cz\/?p=56","title":{"rendered":"Cluster"},"content":{"rendered":"

Sestaven\u00ed clastru<\/p>\n

\/* Target table\/view(s)\u00a0 *\/
\n%let _OUTPUT = L2_spds.PREDPOJ_RIZ;
\n%let _OUTPUT1 = L2_spds.PREDPOJ_RIZ;<\/p>\n

\/* Options\u00a0 *\/
\n%let etls_filter = %nrquote(PREDPOJ_RIZ);
\n%let etls_maxslots = %nrquote(2);<\/p>\n

<\/p>\n

\/* List of target columns to keep\u00a0 *\/
\n%let keep = idsml drpr drzuc kodpp riziko castpr plod pldo datspl datvytv storno muc
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 ruc upisovaci_rok idflot orgj inkr_pk inks_pk smlo_pk prod_pk idri_pk
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 part_pk orgj_pk odve_pk;<\/p>\n

%macro clusterCreateAdd;
\n\/* Input template on PFD is included to allow inserting in a process flow.\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 *\/
\n\/* Use _output macro var to get the name of the library. (Assumes user removed SPDS loader.) *\/
\n%let etls_libref=%scan(&_output,1,.);
\n%let etls_outdsn=%scan(&_output,2,.);<\/p>\n

proc sql;
\n\u00a0\u00a0 create table work.SPDSTMP as
\n\u00a0\u00a0\u00a0\u00a0\u00a0 select memname length = 32
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 from dictionary.tables
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 where upcase(libname) = %upcase(“&etls_libref”) and
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 upcase(memname) ^= %upcase(“&etls_outdsn”);\u00a0
\nquit;<\/p>\n

data _null_;
\n\u00a0 \/*\u00a0 If the cluster already exists\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 *\/
\n\u00a0 \/*\u00a0 then generate code for an add.\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 *\/
\n\u00a0 \/*\u00a0 Otherwise generate code for a create.*\/\u00a0
\n\u00a0 if exist(“&_output”) then
\n\u00a0\u00a0\u00a0\u00a0 call symput(‘etls_exist’,”YES”);\u00a0
\n\u00a0 else
\n\u00a0\u00a0\u00a0\u00a0 call symput(‘etls_exist’,”NO”);
\nrun;<\/p>\n

data _null_;
\n\u00a0\u00a0 set work.SPDSTMP end=eof;\u00a0\u00a0<\/p>\n

\u00a0\u00a0 %if “&etls_filter” ne “” %then
\n\u00a0\u00a0 %do;
\n\u00a0\u00a0\u00a0\u00a0\u00a0 where index(upcase(memname),%upcase(“&etls_filter”)) > 0;
\n\u00a0\u00a0 %end;
\n\u00a0\u00a0
\n\u00a0\u00a0 if _n_=1 then
\n\u00a0\u00a0 do;
\n\u00a0\u00a0\u00a0\u00a0 call execute(“PROC SPDO library=&etls_libref;”);
\n\u00a0\u00a0\u00a0\u00a0 if “&etls_exist”=”YES” then
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(“cluster add &etls_outdsn “);
\n\u00a0\u00a0\u00a0\u00a0 else
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(“cluster create &etls_outdsn “);\u00a0\u00a0\u00a0
\n\u00a0\u00a0 end;
\n\u00a0\u00a0 call execute(” mem=”||memname);
\n\u00a0\u00a0 if eof then do;
\n\u00a0\u00a0\u00a0\u00a0\u00a0 if “&etls_exist”=”YES” then
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(” ; quit;”);
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 else
\n\u00a0\u00a0\u00a0\u00a0\u00a0 \/* Only put the maxslots when creating a *\/
\n\u00a0\u00a0\u00a0\u00a0\u00a0 \/* new cluster.\u00a0 If max slots from the\u00a0\u00a0 *\/
\n\u00a0\u00a0\u00a0\u00a0\u00a0 \/* options tab is 0 then the number of\u00a0\u00a0 *\/
\n\u00a0\u00a0\u00a0\u00a0\u00a0 \/* tables in the library will be used.\u00a0\u00a0 *\/\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 do;
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 length etls_max 8;
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 if &etls_maxslots > 0 then
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 etls_max = &etls_maxslots;
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 else
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 etls_max = _n_;\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(” maxslot=”||trim(left(put(etls_max,8.)))||”; quit;”);\u00a0\u00a0\u00a0\u00a0
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 end;
\n\u00a0\u00a0 end;
\nrun;
\n%mend clusterCreateAdd;
\n%clusterCreateAdd;<\/p>\n

Rozbyt\u00ed clusteru<\/p>\n

\/* Source table(s)\/view(s)\u00a0 *\/
\n%let _INPUT1 = L2_spds.PREDPOJ_RIZ;
\n%macro clusterUndoTables;
\n%let etls_libref=%scan(&_INPUT1,1,.);
\n%let etls_dsn=%scan(&_INPUT1,2,.);
\n\/* Undo removes the cluster definition.\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 *\/
\n\/* The clustered tables are returned to their\u00a0\u00a0 *\/
\n\/* original unclustered state\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 *\/
\ndata _null_;
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(‘Proc spdo library=&etls_libref;’);
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(‘\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 cluster undo &etls_dsn;’);
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 call execute(‘quit;’);
\nrun;
\n%mend clusterUndoTables;
\n%clusterUndoTables;<\/p>\n\n