digraph G {
subgraph clusterstage_41902 {
label="Stage 41902";
183801 [labelType="html" label="JDBCRDD [183801]<br>cache at <unknown>:0"];
subgraph cluster433732 {
label="WholeStageCodegen (1)";
183802 [labelType="html" label="MapPartitionsRDD [183802]<br>count at <unknown>:0"];
}
subgraph cluster433734 {
label="mapPartitionsInternal";
183803 [labelType="html" label="MapPartitionsRDD [183803]<br>count at <unknown>:0"];
}
subgraph cluster433735 {
label="mapPartitionsInternal";
183804 [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#16726646,supplier_id#16726647,entity_name#16726648,city#16726649,state#16726650,country#16726651,supplier_type#16726652,declaring_supplier_id#16726653,canonical_id#16726654,is_primary#16726655,threshold#16726656,create_date#16726657] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [183804] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster433792 {
label="InMemoryTableScan";
183825 [labelType="html" label="MapPartitionsRDD [183825]<br>count at <unknown>:0"];
183826 [labelType="html" label="MapPartitionsRDD [183826]<br>count at <unknown>:0"];
183827 [labelType="html" label="MapPartitionsRDD [183827]<br>count at <unknown>:0"];
}
subgraph cluster433788 {
label="WholeStageCodegen (1)";
183828 [labelType="html" label="MapPartitionsRDD [183828]<br>count at <unknown>:0"];
}
subgraph cluster433793 {
label="mapPartitionsInternal";
183829 [labelType="html" label="MapPartitionsRDD [183829]<br>count at <unknown>:0"];
}
subgraph cluster433794 {
label="mapPartitionsInternal";
183830 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#16726654)\n +- InMemoryTableScan [brand_context_id#16726646, supplier_id#16726647, canonical_id#16726654, is_primary#16726655, entity_name#16726648, city#16726649, state#16726650, country#16726651, threshold#16726656, create_date#16726657], [isnotnull(canonical_id#16726654)]\n +- InMemoryRelation [brand_context_id#16726646, supplier_id#16726647, entity_name#16726648, city#16726649, state#16726650, country#16726651, supplier_type#16726652, declaring_supplier_id#16726653, canonical_id#16726654, is_primary#16726655, threshold#16726656, create_date#16726657], 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 ... [183830] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster433800 {
label="InMemoryTableScan";
183831 [labelType="html" label="MapPartitionsRDD [183831]<br>count at <unknown>:0"];
183832 [labelType="html" label="MapPartitionsRDD [183832]<br>count at <unknown>:0"];
183833 [labelType="html" label="MapPartitionsRDD [183833]<br>count at <unknown>:0"];
}
subgraph cluster433796 {
label="WholeStageCodegen (1)";
183834 [labelType="html" label="MapPartitionsRDD [183834]<br>count at <unknown>:0"];
}
subgraph cluster433795 {
label="Exchange";
183835 [labelType="html" label="MapPartitionsRDD [183835]<br>count at <unknown>:0"];
}
}
183801->183802;
183802->183803;
183803->183804;
183804->183825;
183825->183826;
183826->183827;
183827->183828;
183828->183829;
183829->183830;
183830->183831;
183831->183832;
183832->183833;
183833->183834;
183834->183835;
}
183804
183830