digraph G {
subgraph clusterstage_43870 {
label="Stage 43870";
190607 [labelType="html" label="JDBCRDD [190607]<br>cache at <unknown>:0"];
subgraph cluster449424 {
label="WholeStageCodegen (1)";
190608 [labelType="html" label="MapPartitionsRDD [190608]<br>count at <unknown>:0"];
}
subgraph cluster449426 {
label="mapPartitionsInternal";
190609 [labelType="html" label="MapPartitionsRDD [190609]<br>count at <unknown>:0"];
}
subgraph cluster449427 {
label="mapPartitionsInternal";
190610 [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#17271558,supplier_id#17271559,entity_name#17271560,city#17271561,state#17271562,country#17271563,supplier_type#17271564,declaring_supplier_id#17271565,canonical_id#17271566,is_primary#17271567,threshold#17271568,create_date#17271569] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190610] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster449484 {
label="InMemoryTableScan";
190631 [labelType="html" label="MapPartitionsRDD [190631]<br>count at <unknown>:0"];
190632 [labelType="html" label="MapPartitionsRDD [190632]<br>count at <unknown>:0"];
190633 [labelType="html" label="MapPartitionsRDD [190633]<br>count at <unknown>:0"];
}
subgraph cluster449480 {
label="WholeStageCodegen (1)";
190634 [labelType="html" label="MapPartitionsRDD [190634]<br>count at <unknown>:0"];
}
subgraph cluster449485 {
label="mapPartitionsInternal";
190635 [labelType="html" label="MapPartitionsRDD [190635]<br>count at <unknown>:0"];
}
subgraph cluster449486 {
label="mapPartitionsInternal";
190636 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17271566)\n +- InMemoryTableScan [brand_context_id#17271558, supplier_id#17271559, canonical_id#17271566, is_primary#17271567, entity_name#17271560, city#17271561, state#17271562, country#17271563, threshold#17271568, create_date#17271569], [isnotnull(canonical_id#17271566)]\n +- InMemoryRelation [brand_context_id#17271558, supplier_id#17271559, entity_name#17271560, city#17271561, state#17271562, country#17271563, supplier_type#17271564, declaring_supplier_id#17271565, canonical_id#17271566, is_primary#17271567, threshold#17271568, create_date#17271569], 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 ... [190636] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster449492 {
label="InMemoryTableScan";
190637 [labelType="html" label="MapPartitionsRDD [190637]<br>count at <unknown>:0"];
190638 [labelType="html" label="MapPartitionsRDD [190638]<br>count at <unknown>:0"];
190639 [labelType="html" label="MapPartitionsRDD [190639]<br>count at <unknown>:0"];
}
subgraph cluster449488 {
label="WholeStageCodegen (1)";
190640 [labelType="html" label="MapPartitionsRDD [190640]<br>count at <unknown>:0"];
}
subgraph cluster449487 {
label="Exchange";
190641 [labelType="html" label="MapPartitionsRDD [190641]<br>count at <unknown>:0"];
}
}
190607->190608;
190608->190609;
190609->190610;
190610->190631;
190631->190632;
190632->190633;
190633->190634;
190634->190635;
190635->190636;
190636->190637;
190637->190638;
190638->190639;
190639->190640;
190640->190641;
}
190610
190636