digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 3 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#298145,zd_numdem#298146,zd_numdos#298147,zd_numpco#298148,zd_primai#298149,zd_annval#298150,zd_monnaie#298151,zd_cod_acte#298152,zd_ver_ccam#298153,zd_codsit#298154,zd_coduti#298155,zd_datmaj#298156,zd_cod_aa#298157,zd_modificateur#298158,zd_codper#298159,zd_codser#298160,zd_numsal#298161,zd_flassprev#298162,zd_assnonprev#298163,zd_numord#298164,zd_priuni#298165,zd_coefmino#298166,zd_mino#298167,zd_majo#298168,... 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#298145, zd_numdem#298146, zd_numdos#298147, zd_numpco#298148, zd_primai#298149, zd_annval#298150, zd_monnaie#298151, zd_cod_acte#298152, zd_ver_ccam#298153, zd_codsit#298154, zd_coduti#298155, zd_datmaj#298156, zd_cod_aa#298157, zd_modificateur#298158, zd_codper#298159, zd_codser#298160, zd_numsal#298161, zd_flassprev#298162, zd_assnonprev#298163, zd_numord#298164, zd_priuni#298165, zd_coefmino#298166, zd_mino#298167, zd_majo#298168, zd_basrmb#298169, zd_factur#298170, zd_typexo#298171, zd_taucai#298172, zd_parcai#298173, zd_taumut#298174, zd_parmut#298175, zd_ligrgr#298176, zd_regrou_cod#298177, zd_cod_aap#298178, zd_qualdp#298179, zd_flrmbexc#298180, zd_flsuppcharge#298181, zd_donncompl#298182, zd_dents#298183, zd_depmnt#298184, zd_flid#298185, zd_mttid#298186, zd_tauid#298187, zd_amoid#298188, zd_tauid_amc#298189, zd_amcid#298190, zd_nbrik#298191, zd_mttik#298192, zd_tauik#298193, zd_amoik#298194, zd_nbrikm#298195, zd_mttikm#298196, zd_tauikm#298197, zd_amoikm#298198, zd_nbriks#298199, zd_mttiks#298200, zd_tauiks#298201, zd_amoiks#298202, zd_forc#298203, zd_formamc#298204, zd_codtit#298205, zd_flald#298206, zd_a_fact#298207, zd_x_exo_tm#298208, zd_modiffact#298209, zd_assnonprev_c#298210, zd_qualdp_c#298211, zd_coduam#298212, zd_mtdep#298213, zd_mtpenhps#298214, zd_flpav#298215, zd_mttori#298216, zd_acr#298217, zd_codapp#298218, zd_codper2#298219, zd_codind#298220, zd_codres#298221, zd_codextdoc#298222, zd_numexa#298223, zd_codextpmsi#298224]
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#298145, zd_numdem#298146, zd_numdos#298147, zd_numpco#298148, zd_primai#298149, zd_annval#298150, zd_monnaie#298151, zd_cod_acte#298152, zd_ver_ccam#298153, zd_codsit#298154, zd_coduti#298155, zd_datmaj#298156, zd_cod_aa#298157, zd_modificateur#298158, zd_codper#298159, zd_codser#298160, zd_numsal#298161, zd_flassprev#298162, zd_assnonprev#298163, zd_numord#298164, zd_priuni#298165, zd_coefmino#298166, zd_mino#298167, zd_majo#298168, zd_basrmb#298169, zd_factur#298170, zd_typexo#298171, zd_taucai#298172, zd_parcai#298173, zd_taumut#298174, zd_parmut#298175, zd_ligrgr#298176, zd_regrou_cod#298177, zd_cod_aap#298178, zd_qualdp#298179, zd_flrmbexc#298180, zd_flsuppcharge#298181, zd_donncompl#298182, zd_dents#298183, zd_depmnt#298184, zd_flid#298185, zd_mttid#298186, zd_tauid#298187, zd_amoid#298188, zd_tauid_amc#298189, zd_amcid#298190, zd_nbrik#298191, zd_mttik#298192, zd_tauik#298193, zd_amoik#298194, zd_nbrikm#298195, zd_mttikm#298196, zd_tauikm#298197, zd_amoikm#298198, zd_nbriks#298199, zd_mttiks#298200, zd_tauiks#298201, zd_amoiks#298202, zd_forc#298203, zd_formamc#298204, zd_codtit#298205, zd_flald#298206, zd_a_fact#298207, zd_x_exo_tm#298208, zd_modiffact#298209, zd_assnonprev_c#298210, zd_qualdp_c#298211, zd_coduam#298212, zd_mtdep#298213, zd_mtpenhps#298214, zd_flpav#298215, zd_mttori#298216, zd_acr#298217, zd_codapp#298218, zd_codper2#298219, zd_codind#298220, zd_codres#298221, zd_codextdoc#298222, zd_numexa#298223, zd_codextpmsi#298224]
Arguments: 500