digraph G {
subgraph clusterstage_27634 {
label="Stage 27634";
120901 [labelType="html" label="JDBCRDD [120901]<br>cache at <unknown>:0"];
subgraph cluster302390 {
label="WholeStageCodegen (1)";
120902 [labelType="html" label="MapPartitionsRDD [120902]<br>count at <unknown>:0"];
}
subgraph cluster302392 {
label="mapPartitionsInternal";
120903 [labelType="html" label="MapPartitionsRDD [120903]<br>count at <unknown>:0"];
}
subgraph cluster302393 {
label="mapPartitionsInternal";
120904 [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#12292335,supplier_id#12292336,entity_name#12292337,city#12292338,state#12292339,country#12292340,supplier_type#12292341,declaring_supplier_id#12292342,canonical_id#12292343,is_primary#12292344,threshold#12292345,create_date#12292346] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [120904] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302425 {
label="InMemoryTableScan";
120913 [labelType="html" label="MapPartitionsRDD [120913]<br>count at <unknown>:0"];
120914 [labelType="html" label="MapPartitionsRDD [120914]<br>count at <unknown>:0"];
120915 [labelType="html" label="MapPartitionsRDD [120915]<br>count at <unknown>:0"];
}
subgraph cluster302420 {
label="WholeStageCodegen (1)";
120916 [labelType="html" label="MapPartitionsRDD [120916]<br>count at <unknown>:0"];
}
subgraph cluster302426 {
label="mapPartitionsInternal";
120917 [labelType="html" label="MapPartitionsRDD [120917]<br>count at <unknown>:0"];
}
subgraph cluster302427 {
label="mapPartitionsInternal";
120918 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12292335, supplier_id#12292336, entity_name#12292337, city#12292338, state#12292339, country#12292340, supplier_type#12292341, declaring_supplier_id#12292342, threshold#12292345, create_date#12292346]\n +- Filter isnull(canonical_id#12292343)\n +- InMemoryTableScan [brand_context_id#12292335, canonical_id#12292343, city#12292338, country#12292340, create_date#12292346, declaring_supplier_id#12292342, entity_name#12292337, state#12292339, supplier_id#12292336, supplier_type#12292341, threshold#12292345], [isnull(canonical_id#12292343)]\n +- InMemoryRelation [brand_context_id#12292335, supplier_id#12292336, entity_name#12292337, city#12292338, state#12292339, country#12292340, supplier_type#12292341, declaring_supplier_id#12292342, canonical_id#12292343, is_primary#12292344, threshold#12292345, create_date#12292346], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [120918] [Cached]<br>count at <unknown>:0"];
}
}
120901->120902;
120902->120903;
120903->120904;
120904->120913;
120913->120914;
120914->120915;
120915->120916;
120916->120917;
120917->120918;
}
120904
120918