digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 2 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#301093,zd_numdem#301094,zd_numdos#301095,zd_numpco#301096,zd_primai#301097,zd_annval#301098,zd_monnaie#301099,zd_cod_acte#301100,zd_ver_ccam#301101,zd_codsit#301102,zd_coduti#301103,zd_datmaj#301104,zd_cod_aa#301105,zd_modificateur#301106,zd_codper#301107,zd_codser#301108,zd_numsal#301109,zd_flassprev#301110,zd_assnonprev#301111,zd_numord#301112,zd_priuni#301113,zd_coefmino#301114,zd_mino#301115,zd_majo#301116,... 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#301093, zd_numdem#301094, zd_numdos#301095, zd_numpco#301096, zd_primai#301097, zd_annval#301098, zd_monnaie#301099, zd_cod_acte#301100, zd_ver_ccam#301101, zd_codsit#301102, zd_coduti#301103, zd_datmaj#301104, zd_cod_aa#301105, zd_modificateur#301106, zd_codper#301107, zd_codser#301108, zd_numsal#301109, zd_flassprev#301110, zd_assnonprev#301111, zd_numord#301112, zd_priuni#301113, zd_coefmino#301114, zd_mino#301115, zd_majo#301116, zd_basrmb#301117, zd_factur#301118, zd_typexo#301119, zd_taucai#301120, zd_parcai#301121, zd_taumut#301122, zd_parmut#301123, zd_ligrgr#301124, zd_regrou_cod#301125, zd_cod_aap#301126, zd_qualdp#301127, zd_flrmbexc#301128, zd_flsuppcharge#301129, zd_donncompl#301130, zd_dents#301131, zd_depmnt#301132, zd_flid#301133, zd_mttid#301134, zd_tauid#301135, zd_amoid#301136, zd_tauid_amc#301137, zd_amcid#301138, zd_nbrik#301139, zd_mttik#301140, zd_tauik#301141, zd_amoik#301142, zd_nbrikm#301143, zd_mttikm#301144, zd_tauikm#301145, zd_amoikm#301146, zd_nbriks#301147, zd_mttiks#301148, zd_tauiks#301149, zd_amoiks#301150, zd_forc#301151, zd_formamc#301152, zd_codtit#301153, zd_flald#301154, zd_a_fact#301155, zd_x_exo_tm#301156, zd_modiffact#301157, zd_assnonprev_c#301158, zd_qualdp_c#301159, zd_coduam#301160, zd_mtdep#301161, zd_mtpenhps#301162, zd_flpav#301163, zd_mttori#301164, zd_acr#301165, zd_codapp#301166, zd_codper2#301167, zd_codind#301168, zd_codres#301169, zd_codextdoc#301170, zd_numexa#301171, zd_codextpmsi#301172]
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#301093, zd_numdem#301094, zd_numdos#301095, zd_numpco#301096, zd_primai#301097, zd_annval#301098, zd_monnaie#301099, zd_cod_acte#301100, zd_ver_ccam#301101, zd_codsit#301102, zd_coduti#301103, zd_datmaj#301104, zd_cod_aa#301105, zd_modificateur#301106, zd_codper#301107, zd_codser#301108, zd_numsal#301109, zd_flassprev#301110, zd_assnonprev#301111, zd_numord#301112, zd_priuni#301113, zd_coefmino#301114, zd_mino#301115, zd_majo#301116, zd_basrmb#301117, zd_factur#301118, zd_typexo#301119, zd_taucai#301120, zd_parcai#301121, zd_taumut#301122, zd_parmut#301123, zd_ligrgr#301124, zd_regrou_cod#301125, zd_cod_aap#301126, zd_qualdp#301127, zd_flrmbexc#301128, zd_flsuppcharge#301129, zd_donncompl#301130, zd_dents#301131, zd_depmnt#301132, zd_flid#301133, zd_mttid#301134, zd_tauid#301135, zd_amoid#301136, zd_tauid_amc#301137, zd_amcid#301138, zd_nbrik#301139, zd_mttik#301140, zd_tauik#301141, zd_amoik#301142, zd_nbrikm#301143, zd_mttikm#301144, zd_tauikm#301145, zd_amoikm#301146, zd_nbriks#301147, zd_mttiks#301148, zd_tauiks#301149, zd_amoiks#301150, zd_forc#301151, zd_formamc#301152, zd_codtit#301153, zd_flald#301154, zd_a_fact#301155, zd_x_exo_tm#301156, zd_modiffact#301157, zd_assnonprev_c#301158, zd_qualdp_c#301159, zd_coduam#301160, zd_mtdep#301161, zd_mtpenhps#301162, zd_flpav#301163, zd_mttori#301164, zd_acr#301165, zd_codapp#301166, zd_codper2#301167, zd_codind#301168, zd_codres#301169, zd_codextdoc#301170, zd_numexa#301171, zd_codextpmsi#301172]
Arguments: 500