digraph G {
subgraph clusterstage_37494 {
label="Stage 37494";
161701 [labelType="html" label="JDBCRDD [161701]<br>cache at <unknown>:0"];
subgraph cluster389659 {
label="WholeStageCodegen (1)";
161702 [labelType="html" label="MapPartitionsRDD [161702]<br>count at <unknown>:0"];
}
subgraph cluster389661 {
label="mapPartitionsInternal";
161703 [labelType="html" label="MapPartitionsRDD [161703]<br>count at <unknown>:0"];
}
subgraph cluster389662 {
label="mapPartitionsInternal";
161704 [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#15202060,supplier_id#15202061,entity_name#15202062,city#15202063,state#15202064,country#15202065,supplier_type#15202066,declaring_supplier_id#15202067,canonical_id#15202068,is_primary#15202069,threshold#15202070,create_date#15202071] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [161704] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster389719 {
label="InMemoryTableScan";
161725 [labelType="html" label="MapPartitionsRDD [161725]<br>count at <unknown>:0"];
161726 [labelType="html" label="MapPartitionsRDD [161726]<br>count at <unknown>:0"];
161727 [labelType="html" label="MapPartitionsRDD [161727]<br>count at <unknown>:0"];
}
subgraph cluster389715 {
label="WholeStageCodegen (1)";
161728 [labelType="html" label="MapPartitionsRDD [161728]<br>count at <unknown>:0"];
}
subgraph cluster389720 {
label="mapPartitionsInternal";
161729 [labelType="html" label="MapPartitionsRDD [161729]<br>count at <unknown>:0"];
}
subgraph cluster389721 {
label="mapPartitionsInternal";
161730 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#15202068)\n +- InMemoryTableScan [brand_context_id#15202060, supplier_id#15202061, canonical_id#15202068, is_primary#15202069, entity_name#15202062, city#15202063, state#15202064, country#15202065, threshold#15202070, create_date#15202071], [isnotnull(canonical_id#15202068)]\n +- InMemoryRelation [brand_context_id#15202060, supplier_id#15202061, entity_name#15202062, city#15202063, state#15202064, country#15202065, supplier_type#15202066, declaring_supplier_id#15202067, canonical_id#15202068, is_primary#15202069, threshold#15202070, create_date#15202071], 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 ... [161730] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster389727 {
label="InMemoryTableScan";
161731 [labelType="html" label="MapPartitionsRDD [161731]<br>count at <unknown>:0"];
161732 [labelType="html" label="MapPartitionsRDD [161732]<br>count at <unknown>:0"];
161733 [labelType="html" label="MapPartitionsRDD [161733]<br>count at <unknown>:0"];
}
subgraph cluster389723 {
label="WholeStageCodegen (1)";
161734 [labelType="html" label="MapPartitionsRDD [161734]<br>count at <unknown>:0"];
}
subgraph cluster389722 {
label="Exchange";
161735 [labelType="html" label="MapPartitionsRDD [161735]<br>count at <unknown>:0"];
}
}
161701->161702;
161702->161703;
161703->161704;
161704->161725;
161725->161726;
161726->161727;
161727->161728;
161728->161729;
161729->161730;
161730->161731;
161731->161732;
161732->161733;
161733->161734;
161734->161735;
}
161704
161730