digraph G {
subgraph clusterstage_1054 {
label="Stage 1054";
3631 [labelType="html" label="JDBCRDD [3631]<br>cache at <unknown>:0"];
subgraph cluster8392 {
label="WholeStageCodegen (1)";
3632 [labelType="html" label="MapPartitionsRDD [3632]<br>count at <unknown>:0"];
}
subgraph cluster8394 {
label="mapPartitionsInternal";
3633 [labelType="html" label="MapPartitionsRDD [3633]<br>count at <unknown>:0"];
}
subgraph cluster8395 {
label="mapPartitionsInternal";
3634 [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#281342,supplier_id#281343,entity_name#281344,city#281345,state#281346,country#281347,supplier_type#281348,declaring_supplier_id#281349,canonical_id#281350,is_primary#281351,threshold#281352,create_date#281353] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3634] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8427 {
label="InMemoryTableScan";
3643 [labelType="html" label="MapPartitionsRDD [3643]<br>count at <unknown>:0"];
3644 [labelType="html" label="MapPartitionsRDD [3644]<br>count at <unknown>:0"];
3645 [labelType="html" label="MapPartitionsRDD [3645]<br>count at <unknown>:0"];
}
subgraph cluster8422 {
label="WholeStageCodegen (1)";
3646 [labelType="html" label="MapPartitionsRDD [3646]<br>count at <unknown>:0"];
}
subgraph cluster8428 {
label="mapPartitionsInternal";
3647 [labelType="html" label="MapPartitionsRDD [3647]<br>count at <unknown>:0"];
}
subgraph cluster8429 {
label="mapPartitionsInternal";
3648 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#281342, supplier_id#281343, entity_name#281344, city#281345, state#281346, country#281347, supplier_type#281348, declaring_supplier_id#281349, threshold#281352, create_date#281353]\n +- Filter isnull(canonical_id#281350)\n +- InMemoryTableScan [brand_context_id#281342, canonical_id#281350, city#281345, country#281347, create_date#281353, declaring_supplier_id#281349, entity_name#281344, state#281346, supplier_id#281343, supplier_type#281348, threshold#281352], [isnull(canonical_id#281350)]\n +- InMemoryRelation [brand_context_id#281342, supplier_id#281343, entity_name#281344, city#281345, state#281346, country#281347, supplier_type#281348, declaring_supplier_id#281349, canonical_id#281350, is_primary#281351, threshold#281352, create_date#281353], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [3648] [Cached]<br>count at <unknown>:0"];
}
}
3631->3632;
3632->3633;
3633->3634;
3634->3643;
3643->3644;
3644->3645;
3645->3646;
3646->3647;
3647->3648;
}
3634
3648