digraph G {
subgraph clusterstage_1421 {
label="Stage 1421";
4885 [labelType="html" label="JDBCRDD [4885]<br>cache at <unknown>:0"];
subgraph cluster11395 {
label="WholeStageCodegen (1)";
4886 [labelType="html" label="MapPartitionsRDD [4886]<br>count at <unknown>:0"];
}
subgraph cluster11397 {
label="mapPartitionsInternal";
4887 [labelType="html" label="MapPartitionsRDD [4887]<br>count at <unknown>:0"];
}
subgraph cluster11398 {
label="mapPartitionsInternal";
4888 [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#330215,supplier_id#330216,entity_name#330217,city#330218,state#330219,country#330220,supplier_type#330221,declaring_supplier_id#330222,canonical_id#330223,is_primary#330224,threshold#330225,create_date#330226] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4888] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11455 {
label="InMemoryTableScan";
4909 [labelType="html" label="MapPartitionsRDD [4909]<br>count at <unknown>:0"];
4910 [labelType="html" label="MapPartitionsRDD [4910]<br>count at <unknown>:0"];
4911 [labelType="html" label="MapPartitionsRDD [4911]<br>count at <unknown>:0"];
}
subgraph cluster11451 {
label="WholeStageCodegen (1)";
4912 [labelType="html" label="MapPartitionsRDD [4912]<br>count at <unknown>:0"];
}
subgraph cluster11456 {
label="mapPartitionsInternal";
4913 [labelType="html" label="MapPartitionsRDD [4913]<br>count at <unknown>:0"];
}
subgraph cluster11457 {
label="mapPartitionsInternal";
4914 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#330223)\n +- InMemoryTableScan [brand_context_id#330215, supplier_id#330216, canonical_id#330223, is_primary#330224, entity_name#330217, city#330218, state#330219, country#330220, threshold#330225, create_date#330226], [isnotnull(canonical_id#330223)]\n +- InMemoryRelation [brand_context_id#330215, supplier_id#330216, entity_name#330217, city#330218, state#330219, country#330220, supplier_type#330221, declaring_supplier_id#330222, canonical_id#330223, is_primary#330224, threshold#330225, create_date#330226], 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... [4914] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11463 {
label="InMemoryTableScan";
4915 [labelType="html" label="MapPartitionsRDD [4915]<br>count at <unknown>:0"];
4916 [labelType="html" label="MapPartitionsRDD [4916]<br>count at <unknown>:0"];
4917 [labelType="html" label="MapPartitionsRDD [4917]<br>count at <unknown>:0"];
}
subgraph cluster11459 {
label="WholeStageCodegen (1)";
4918 [labelType="html" label="MapPartitionsRDD [4918]<br>count at <unknown>:0"];
}
subgraph cluster11458 {
label="Exchange";
4919 [labelType="html" label="MapPartitionsRDD [4919]<br>count at <unknown>:0"];
}
}
4885->4886;
4886->4887;
4887->4888;
4888->4909;
4909->4910;
4910->4911;
4911->4912;
4912->4913;
4913->4914;
4914->4915;
4915->4916;
4916->4917;
4917->4918;
4918->4919;
}
4888
4914