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 \"xplore2\".\"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 "xplore2"."h_ccamdet") as x limit 200) as x) [numPartitions=1] [zd_numcot#300852,zd_numdem#300853,zd_numdos#300854,zd_numpco#300855,zd_primai#300856,zd_annval#300857,zd_monnaie#300858,zd_cod_acte#300859,zd_ver_ccam#300860,zd_codsit#300861,zd_coduti#300862,zd_datmaj#300863,zd_cod_aa#300864,zd_modificateur#300865,zd_codper#300866,zd_codser#300867,zd_numsal#300868,zd_flassprev#300869,zd_assnonprev#300870,zd_numord#300871,zd_priuni#300872,zd_coefmino#300873,zd_mino#300874,zd_majo#300875,... 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 "xplore2"."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 "xplore2"."h_ccamdet") as x limit 200) as x) [numPartitions=1] [codegen id : 1]
Output [80]: [zd_numcot#300852, zd_numdem#300853, zd_numdos#300854, zd_numpco#300855, zd_primai#300856, zd_annval#300857, zd_monnaie#300858, zd_cod_acte#300859, zd_ver_ccam#300860, zd_codsit#300861, zd_coduti#300862, zd_datmaj#300863, zd_cod_aa#300864, zd_modificateur#300865, zd_codper#300866, zd_codser#300867, zd_numsal#300868, zd_flassprev#300869, zd_assnonprev#300870, zd_numord#300871, zd_priuni#300872, zd_coefmino#300873, zd_mino#300874, zd_majo#300875, zd_basrmb#300876, zd_factur#300877, zd_typexo#300878, zd_taucai#300879, zd_parcai#300880, zd_taumut#300881, zd_parmut#300882, zd_ligrgr#300883, zd_regrou_cod#300884, zd_cod_aap#300885, zd_qualdp#300886, zd_flrmbexc#300887, zd_flsuppcharge#300888, zd_donncompl#300889, zd_dents#300890, zd_depmnt#300891, zd_flid#300892, zd_mttid#300893, zd_tauid#300894, zd_amoid#300895, zd_tauid_amc#300896, zd_amcid#300897, zd_nbrik#300898, zd_mttik#300899, zd_tauik#300900, zd_amoik#300901, zd_nbrikm#300902, zd_mttikm#300903, zd_tauikm#300904, zd_amoikm#300905, zd_nbriks#300906, zd_mttiks#300907, zd_tauiks#300908, zd_amoiks#300909, zd_forc#300910, zd_formamc#300911, zd_codtit#300912, zd_flald#300913, zd_a_fact#300914, zd_x_exo_tm#300915, zd_modiffact#300916, zd_assnonprev_c#300917, zd_qualdp_c#300918, zd_coduam#300919, zd_mtdep#300920, zd_mtpenhps#300921, zd_flpav#300922, zd_mttori#300923, zd_acr#300924, zd_codapp#300925, zd_codper2#300926, zd_codind#300927, zd_codres#300928, zd_codextdoc#300929, zd_numexa#300930, zd_codextpmsi#300931]
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#300852, zd_numdem#300853, zd_numdos#300854, zd_numpco#300855, zd_primai#300856, zd_annval#300857, zd_monnaie#300858, zd_cod_acte#300859, zd_ver_ccam#300860, zd_codsit#300861, zd_coduti#300862, zd_datmaj#300863, zd_cod_aa#300864, zd_modificateur#300865, zd_codper#300866, zd_codser#300867, zd_numsal#300868, zd_flassprev#300869, zd_assnonprev#300870, zd_numord#300871, zd_priuni#300872, zd_coefmino#300873, zd_mino#300874, zd_majo#300875, zd_basrmb#300876, zd_factur#300877, zd_typexo#300878, zd_taucai#300879, zd_parcai#300880, zd_taumut#300881, zd_parmut#300882, zd_ligrgr#300883, zd_regrou_cod#300884, zd_cod_aap#300885, zd_qualdp#300886, zd_flrmbexc#300887, zd_flsuppcharge#300888, zd_donncompl#300889, zd_dents#300890, zd_depmnt#300891, zd_flid#300892, zd_mttid#300893, zd_tauid#300894, zd_amoid#300895, zd_tauid_amc#300896, zd_amcid#300897, zd_nbrik#300898, zd_mttik#300899, zd_tauik#300900, zd_amoik#300901, zd_nbrikm#300902, zd_mttikm#300903, zd_tauikm#300904, zd_amoikm#300905, zd_nbriks#300906, zd_mttiks#300907, zd_tauiks#300908, zd_amoiks#300909, zd_forc#300910, zd_formamc#300911, zd_codtit#300912, zd_flald#300913, zd_a_fact#300914, zd_x_exo_tm#300915, zd_modiffact#300916, zd_assnonprev_c#300917, zd_qualdp_c#300918, zd_coduam#300919, zd_mtdep#300920, zd_mtpenhps#300921, zd_flpav#300922, zd_mttori#300923, zd_acr#300924, zd_codapp#300925, zd_codper2#300926, zd_codind#300927, zd_codres#300928, zd_codextdoc#300929, zd_numexa#300930, zd_codextpmsi#300931]
Arguments: 500