digraph G {
subgraph clusterstage_28731 {
label="Stage 28731";
124684 [labelType="html" label="JDBCRDD [124684]<br>cache at <unknown>:0"];
subgraph cluster311146 {
label="WholeStageCodegen (1)";
124685 [labelType="html" label="MapPartitionsRDD [124685]<br>count at <unknown>:0"];
}
subgraph cluster311148 {
label="mapPartitionsInternal";
124686 [labelType="html" label="MapPartitionsRDD [124686]<br>count at <unknown>:0"];
}
subgraph cluster311149 {
label="mapPartitionsInternal";
124687 [labelType="html" label="*(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.supplier_id,\n v.entity_name,\n v.city,\n v.state,\n v.country,\n v.supplier_type,\n v.declaring_supplier_id,\n v.canonical_id,\n v.is_primary,\n COALESCE(v.threshold, 0.9) AS threshold,\n v.create_date\n FROM vw_all_suppliers_for_dedup v\n ) AS all_suppliers) [numPartitions=1] [brand_context_id#12579601,supplier_id#12579602,entity_name#12579603,city#12579604,state#12579605,country#12579606,supplier_type#12579607,declaring_supplier_id#12579608,canonical_id#12579609,is_primary#12579610,threshold#12579611,create_date#12579612] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124687] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311206 {
label="InMemoryTableScan";
124708 [labelType="html" label="MapPartitionsRDD [124708]<br>count at <unknown>:0"];
124709 [labelType="html" label="MapPartitionsRDD [124709]<br>count at <unknown>:0"];
124710 [labelType="html" label="MapPartitionsRDD [124710]<br>count at <unknown>:0"];
}
subgraph cluster311202 {
label="WholeStageCodegen (1)";
124711 [labelType="html" label="MapPartitionsRDD [124711]<br>count at <unknown>:0"];
}
subgraph cluster311207 {
label="mapPartitionsInternal";
124712 [labelType="html" label="MapPartitionsRDD [124712]<br>count at <unknown>:0"];
}
subgraph cluster311208 {
label="mapPartitionsInternal";
124713 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12579609)\n +- InMemoryTableScan [brand_context_id#12579601, supplier_id#12579602, canonical_id#12579609, is_primary#12579610, entity_name#12579603, city#12579604, state#12579605, country#12579606, threshold#12579611, create_date#12579612], [isnotnull(canonical_id#12579609)]\n +- InMemoryRelation [brand_context_id#12579601, supplier_id#12579602, entity_name#12579603, city#12579604, state#12579605, country#12579606, supplier_type#12579607, declaring_supplier_id#12579608, canonical_id#12579609, is_primary#12579610, threshold#12579611, create_date#12579612], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.supplier_id,\n v.entity_name,\n v.city,\n v.state,\n v.country,\n v.supplier_type,\n v.declaring_supplier_id,\n ... [124713] [Cached]<br>count at <unknown>:0"];
}
}
124684->124685;
124685->124686;
124686->124687;
124687->124708;
124708->124709;
124709->124710;
124710->124711;
124711->124712;
124712->124713;
}
124687
124713