digraph G {
subgraph clusterstage_849 {
label="Stage 849";
2909 [labelType="html" label="JDBCRDD [2909]<br>cache at <unknown>:0"];
subgraph cluster6663 {
label="WholeStageCodegen (1)";
2910 [labelType="html" label="MapPartitionsRDD [2910]<br>count at <unknown>:0"];
}
subgraph cluster6665 {
label="mapPartitionsInternal";
2911 [labelType="html" label="MapPartitionsRDD [2911]<br>count at <unknown>:0"];
}
subgraph cluster6666 {
label="mapPartitionsInternal";
2912 [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#253203,supplier_id#253204,entity_name#253205,city#253206,state#253207,country#253208,supplier_type#253209,declaring_supplier_id#253210,canonical_id#253211,is_primary#253212,threshold#253213,create_date#253214] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [2912] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster6723 {
label="InMemoryTableScan";
2933 [labelType="html" label="MapPartitionsRDD [2933]<br>count at <unknown>:0"];
2934 [labelType="html" label="MapPartitionsRDD [2934]<br>count at <unknown>:0"];
2935 [labelType="html" label="MapPartitionsRDD [2935]<br>count at <unknown>:0"];
}
subgraph cluster6719 {
label="WholeStageCodegen (1)";
2936 [labelType="html" label="MapPartitionsRDD [2936]<br>count at <unknown>:0"];
}
subgraph cluster6724 {
label="mapPartitionsInternal";
2937 [labelType="html" label="MapPartitionsRDD [2937]<br>count at <unknown>:0"];
}
subgraph cluster6725 {
label="mapPartitionsInternal";
2938 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#253211)\n +- InMemoryTableScan [brand_context_id#253203, supplier_id#253204, canonical_id#253211, is_primary#253212, entity_name#253205, city#253206, state#253207, country#253208, threshold#253213, create_date#253214], [isnotnull(canonical_id#253211)]\n +- InMemoryRelation [brand_context_id#253203, supplier_id#253204, entity_name#253205, city#253206, state#253207, country#253208, supplier_type#253209, declaring_supplier_id#253210, canonical_id#253211, is_primary#253212, threshold#253213, create_date#253214], 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 v.canonical_id,\n v.is_prima... [2938] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster6731 {
label="InMemoryTableScan";
2939 [labelType="html" label="MapPartitionsRDD [2939]<br>count at <unknown>:0"];
2940 [labelType="html" label="MapPartitionsRDD [2940]<br>count at <unknown>:0"];
2941 [labelType="html" label="MapPartitionsRDD [2941]<br>count at <unknown>:0"];
}
subgraph cluster6727 {
label="WholeStageCodegen (1)";
2942 [labelType="html" label="MapPartitionsRDD [2942]<br>count at <unknown>:0"];
}
subgraph cluster6726 {
label="Exchange";
2943 [labelType="html" label="MapPartitionsRDD [2943]<br>count at <unknown>:0"];
}
}
2909->2910;
2910->2911;
2911->2912;
2912->2933;
2933->2934;
2934->2935;
2935->2936;
2936->2937;
2937->2938;
2938->2939;
2939->2940;
2940->2941;
2941->2942;
2942->2943;
}
2912
2938