digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 4 ms";
2 [labelType="html" label="<b>Scan JDBCRelation((select * from (SELECT \"zd_numcot\", \"zd_numdem\", \"zd_numdos\", \"zd_numpco\", \"zd_primai\", \"zd_annval\", \"zd_monnaie\", \"zd_cod_acte\", \"zd_ver_ccam\", \"zd_codsit\", \"zd_coduti\", \"zd_datmaj\", \"zd_cod_aa\", \"zd_modificateur\", \"zd_codper\", \"zd_codser\", \"zd_numsal\", \"zd_flassprev\", \"zd_assnonprev\", \"zd_numord\", \"zd_priuni\", \"zd_coefmino\", \"zd_mino\", \"zd_majo\", \"zd_basrmb\", \"zd_factur\", \"zd_typexo\", \"zd_taucai\", \"zd_parcai\", \"zd_taumut\", \"zd_parmut\", \"zd_ligrgr\", \"zd_regrou_cod\", \"zd_cod_aap\", \"zd_qualdp\", \"zd_flrmbexc\", \"zd_flsuppcharge\", \"zd_donncompl\", \"zd_dents\", \"zd_depmnt\", \"zd_flid\", \"zd_mttid\", \"zd_tauid\", \"zd_amoid\", \"zd_tauid_amc\", \"zd_amcid\", \"zd_nbrik\", \"zd_mttik\", \"zd_tauik\", \"zd_amoik\", \"zd_nbrikm\", \"zd_mttikm\", \"zd_tauikm\", \"zd_amoikm\", \"zd_nbriks\", \"zd_mttiks\", \"zd_tauiks\", \"zd_amoiks\", \"zd_forc\", \"zd_formamc\", \"zd_codtit\", \"zd_flald\", \"zd_a_fact\", \"zd_x_exo_tm\", \"zd_modiffact\", \"zd_assnonprev_c\", \"zd_qualdp_c\", \"zd_coduam\", \"zd_mtdep\", \"zd_mtpenhps\", \"zd_flpav\", \"zd_mttori\", \"zd_acr\", \"zd_codapp\", \"zd_codper2\", \"zd_codind\", \"zd_codres\", \"zd_codextdoc\", \"zd_numexa\", \"zd_codextpmsi\" FROM \"xplore\".\"h_ccamdet\") as x limit 200) as x) [numPartitions=1] </b><br><br>number of output rows: 200"];
}
2->0;
}
3
CollectLimit 500
Scan JDBCRelation((select * from (SELECT "zd_numcot", "zd_numdem", "zd_numdos", "zd_numpco", "zd_primai", "zd_annval", "zd_monnaie", "zd_cod_acte", "zd_ver_ccam", "zd_codsit", "zd_coduti", "zd_datmaj", "zd_cod_aa", "zd_modificateur", "zd_codper", "zd_codser", "zd_numsal", "zd_flassprev", "zd_assnonprev", "zd_numord", "zd_priuni", "zd_coefmino", "zd_mino", "zd_majo", "zd_basrmb", "zd_factur", "zd_typexo", "zd_taucai", "zd_parcai", "zd_taumut", "zd_parmut", "zd_ligrgr", "zd_regrou_cod", "zd_cod_aap", "zd_qualdp", "zd_flrmbexc", "zd_flsuppcharge", "zd_donncompl", "zd_dents", "zd_depmnt", "zd_flid", "zd_mttid", "zd_tauid", "zd_amoid", "zd_tauid_amc", "zd_amcid", "zd_nbrik", "zd_mttik", "zd_tauik", "zd_amoik", "zd_nbrikm", "zd_mttikm", "zd_tauikm", "zd_amoikm", "zd_nbriks", "zd_mttiks", "zd_tauiks", "zd_amoiks", "zd_forc", "zd_formamc", "zd_codtit", "zd_flald", "zd_a_fact", "zd_x_exo_tm", "zd_modiffact", "zd_assnonprev_c", "zd_qualdp_c", "zd_coduam", "zd_mtdep", "zd_mtpenhps", "zd_flpav", "zd_mttori", "zd_acr", "zd_codapp", "zd_codper2", "zd_codind", "zd_codres", "zd_codextdoc", "zd_numexa", "zd_codextpmsi" FROM "xplore"."h_ccamdet") as x limit 200) as x) [numPartitions=1] [zd_numcot#295484,zd_numdem#295485,zd_numdos#295486,zd_numpco#295487,zd_primai#295488,zd_annval#295489,zd_monnaie#295490,zd_cod_acte#295491,zd_ver_ccam#295492,zd_codsit#295493,zd_coduti#295494,zd_datmaj#295495,zd_cod_aa#295496,zd_modificateur#295497,zd_codper#295498,zd_codser#295499,zd_numsal#295500,zd_flassprev#295501,zd_assnonprev#295502,zd_numord#295503,zd_priuni#295504,zd_coefmino#295505,zd_mino#295506,zd_majo#295507,... 56 more fields] PushedFilters: [], ReadSchema: struct<zd_numcot:string,zd_numdem:string,zd_numdos:string,zd_numpco:string,zd_primai:string,zd_an...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (2)
+- * Scan JDBCRelation((select * from (SELECT "zd_numcot", "zd_numdem", "zd_numdos", "zd_numpco", "zd_primai", "zd_annval", "zd_monnaie", "zd_cod_acte", "zd_ver_ccam", "zd_codsit", "zd_coduti", "zd_datmaj", "zd_cod_aa", "zd_modificateur", "zd_codper", "zd_codser", "zd_numsal", "zd_flassprev", "zd_assnonprev", "zd_numord", "zd_priuni", "zd_coefmino", "zd_mino", "zd_majo", "zd_basrmb", "zd_factur", "zd_typexo", "zd_taucai", "zd_parcai", "zd_taumut", "zd_parmut", "zd_ligrgr", "zd_regrou_cod", "zd_cod_aap", "zd_qualdp", "zd_flrmbexc", "zd_flsuppcharge", "zd_donncompl", "zd_dents", "zd_depmnt", "zd_flid", "zd_mttid", "zd_tauid", "zd_amoid", "zd_tauid_amc", "zd_amcid", "zd_nbrik", "zd_mttik", "zd_tauik", "zd_amoik", "zd_nbrikm", "zd_mttikm", "zd_tauikm", "zd_amoikm", "zd_nbriks", "zd_mttiks", "zd_tauiks", "zd_amoiks", "zd_forc", "zd_formamc", "zd_codtit", "zd_flald", "zd_a_fact", "zd_x_exo_tm", "zd_modiffact", "zd_assnonprev_c", "zd_qualdp_c", "zd_coduam", "zd_mtdep", "zd_mtpenhps", "zd_flpav", "zd_mttori", "zd_acr", "zd_codapp", "zd_codper2", "zd_codind", "zd_codres", "zd_codextdoc", "zd_numexa", "zd_codextpmsi" FROM "xplore"."h_ccamdet") as x limit 200) as x) [numPartitions=1] (1)
(1) Scan JDBCRelation((select * from (SELECT "zd_numcot", "zd_numdem", "zd_numdos", "zd_numpco", "zd_primai", "zd_annval", "zd_monnaie", "zd_cod_acte", "zd_ver_ccam", "zd_codsit", "zd_coduti", "zd_datmaj", "zd_cod_aa", "zd_modificateur", "zd_codper", "zd_codser", "zd_numsal", "zd_flassprev", "zd_assnonprev", "zd_numord", "zd_priuni", "zd_coefmino", "zd_mino", "zd_majo", "zd_basrmb", "zd_factur", "zd_typexo", "zd_taucai", "zd_parcai", "zd_taumut", "zd_parmut", "zd_ligrgr", "zd_regrou_cod", "zd_cod_aap", "zd_qualdp", "zd_flrmbexc", "zd_flsuppcharge", "zd_donncompl", "zd_dents", "zd_depmnt", "zd_flid", "zd_mttid", "zd_tauid", "zd_amoid", "zd_tauid_amc", "zd_amcid", "zd_nbrik", "zd_mttik", "zd_tauik", "zd_amoik", "zd_nbrikm", "zd_mttikm", "zd_tauikm", "zd_amoikm", "zd_nbriks", "zd_mttiks", "zd_tauiks", "zd_amoiks", "zd_forc", "zd_formamc", "zd_codtit", "zd_flald", "zd_a_fact", "zd_x_exo_tm", "zd_modiffact", "zd_assnonprev_c", "zd_qualdp_c", "zd_coduam", "zd_mtdep", "zd_mtpenhps", "zd_flpav", "zd_mttori", "zd_acr", "zd_codapp", "zd_codper2", "zd_codind", "zd_codres", "zd_codextdoc", "zd_numexa", "zd_codextpmsi" FROM "xplore"."h_ccamdet") as x limit 200) as x) [numPartitions=1] [codegen id : 1]
Output [80]: [zd_numcot#295484, zd_numdem#295485, zd_numdos#295486, zd_numpco#295487, zd_primai#295488, zd_annval#295489, zd_monnaie#295490, zd_cod_acte#295491, zd_ver_ccam#295492, zd_codsit#295493, zd_coduti#295494, zd_datmaj#295495, zd_cod_aa#295496, zd_modificateur#295497, zd_codper#295498, zd_codser#295499, zd_numsal#295500, zd_flassprev#295501, zd_assnonprev#295502, zd_numord#295503, zd_priuni#295504, zd_coefmino#295505, zd_mino#295506, zd_majo#295507, zd_basrmb#295508, zd_factur#295509, zd_typexo#295510, zd_taucai#295511, zd_parcai#295512, zd_taumut#295513, zd_parmut#295514, zd_ligrgr#295515, zd_regrou_cod#295516, zd_cod_aap#295517, zd_qualdp#295518, zd_flrmbexc#295519, zd_flsuppcharge#295520, zd_donncompl#295521, zd_dents#295522, zd_depmnt#295523, zd_flid#295524, zd_mttid#295525, zd_tauid#295526, zd_amoid#295527, zd_tauid_amc#295528, zd_amcid#295529, zd_nbrik#295530, zd_mttik#295531, zd_tauik#295532, zd_amoik#295533, zd_nbrikm#295534, zd_mttikm#295535, zd_tauikm#295536, zd_amoikm#295537, zd_nbriks#295538, zd_mttiks#295539, zd_tauiks#295540, zd_amoiks#295541, zd_forc#295542, zd_formamc#295543, zd_codtit#295544, zd_flald#295545, zd_a_fact#295546, zd_x_exo_tm#295547, zd_modiffact#295548, zd_assnonprev_c#295549, zd_qualdp_c#295550, zd_coduam#295551, zd_mtdep#295552, zd_mtpenhps#295553, zd_flpav#295554, zd_mttori#295555, zd_acr#295556, zd_codapp#295557, zd_codper2#295558, zd_codind#295559, zd_codres#295560, zd_codextdoc#295561, zd_numexa#295562, zd_codextpmsi#295563]
ReadSchema: struct<zd_numcot:string,zd_numdem:string,zd_numdos:string,zd_numpco:string,zd_primai:string,zd_annval:string,zd_monnaie:string,zd_cod_acte:string,zd_ver_ccam:string,zd_codsit:string,zd_coduti:string,zd_datmaj:string,zd_cod_aa:string,zd_modificateur:string,zd_codper:string,zd_codser:string,zd_numsal:string,zd_flassprev:string,zd_assnonprev:string,zd_numord:string,zd_priuni:string,zd_coefmino:string,zd_mino:string,zd_majo:string,zd_basrmb:string,zd_factur:string,zd_typexo:string,zd_taucai:string,zd_parcai:string,zd_taumut:string,zd_parmut:string,zd_ligrgr:string,zd_regrou_cod:string,zd_cod_aap:string,zd_qualdp:string,zd_flrmbexc:string,zd_flsuppcharge:string,zd_donncompl:string,zd_dents:string,zd_depmnt:string,zd_flid:string,zd_mttid:string,zd_tauid:string,zd_amoid:string,zd_tauid_amc:string,zd_amcid:string,zd_nbrik:string,zd_mttik:string,zd_tauik:string,zd_amoik:string,zd_nbrikm:string,zd_mttikm:string,zd_tauikm:string,zd_amoikm:string,zd_nbriks:string,zd_mttiks:string,zd_tauiks:string,zd_amoiks:string,zd_forc:string,zd_formamc:string,zd_codtit:string,zd_flald:string,zd_a_fact:string,zd_x_exo_tm:string,zd_modiffact:string,zd_assnonprev_c:string,zd_qualdp_c:string,zd_coduam:string,zd_mtdep:string,zd_mtpenhps:string,zd_flpav:string,zd_mttori:string,zd_acr:string,zd_codapp:string,zd_codper2:string,zd_codind:string,zd_codres:string,zd_codextdoc:string,zd_numexa:string,zd_codextpmsi:string>
(2) CollectLimit
Input [80]: [zd_numcot#295484, zd_numdem#295485, zd_numdos#295486, zd_numpco#295487, zd_primai#295488, zd_annval#295489, zd_monnaie#295490, zd_cod_acte#295491, zd_ver_ccam#295492, zd_codsit#295493, zd_coduti#295494, zd_datmaj#295495, zd_cod_aa#295496, zd_modificateur#295497, zd_codper#295498, zd_codser#295499, zd_numsal#295500, zd_flassprev#295501, zd_assnonprev#295502, zd_numord#295503, zd_priuni#295504, zd_coefmino#295505, zd_mino#295506, zd_majo#295507, zd_basrmb#295508, zd_factur#295509, zd_typexo#295510, zd_taucai#295511, zd_parcai#295512, zd_taumut#295513, zd_parmut#295514, zd_ligrgr#295515, zd_regrou_cod#295516, zd_cod_aap#295517, zd_qualdp#295518, zd_flrmbexc#295519, zd_flsuppcharge#295520, zd_donncompl#295521, zd_dents#295522, zd_depmnt#295523, zd_flid#295524, zd_mttid#295525, zd_tauid#295526, zd_amoid#295527, zd_tauid_amc#295528, zd_amcid#295529, zd_nbrik#295530, zd_mttik#295531, zd_tauik#295532, zd_amoik#295533, zd_nbrikm#295534, zd_mttikm#295535, zd_tauikm#295536, zd_amoikm#295537, zd_nbriks#295538, zd_mttiks#295539, zd_tauiks#295540, zd_amoiks#295541, zd_forc#295542, zd_formamc#295543, zd_codtit#295544, zd_flald#295545, zd_a_fact#295546, zd_x_exo_tm#295547, zd_modiffact#295548, zd_assnonprev_c#295549, zd_qualdp_c#295550, zd_coduam#295551, zd_mtdep#295552, zd_mtpenhps#295553, zd_flpav#295554, zd_mttori#295555, zd_acr#295556, zd_codapp#295557, zd_codper2#295558, zd_codind#295559, zd_codres#295560, zd_codextdoc#295561, zd_numexa#295562, zd_codextpmsi#295563]
Arguments: 500