== Physical Plan ==
AdaptiveSparkPlan (14)
+- == Final Plan ==
DeserializeToObject (10)
+- * Project (9)
+- * Filter (8)
+- TableCacheQueryStage (7), Statistics(sizeInBytes=25.8 KiB, rowCount=37)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (6)
+- Exchange (5)
+- Project (4)
+- Scan JDBCRelation((
SELECT
pfd._id, pfd.product_node_response_ref,
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
pfd.facility_declaration_ref, pfd.data_facility_dec_ref, pfd.derived_facility_dec_ref,
pfd.facility_name, pfd.data_facility_name,
pfd.fac_city, pfd.data_city, pfd.fac_state, pfd.data_state,
pfd.fac_country, pfd.data_country, pfd.fac_address_line1, pfd.data_address_line1,
pfd.enabled, pfd.facility_default_ref, pfd.Subcontractor_supplier_default_ref,
pfd.sub_contractor, pfd.facility_subcontartor, pfd.Sub_supplier_declaration_ref,
pfd.supplier_declaration_ref, pfd.Value_process, pfd.data_key_values, pfd.update_ts,
pfd.data_subcon_address_city, pfd.data_subcon_address_state, pfd.data_subcon_address_country,
pfd.data_subcon_address_lat, pfd.data_subcon_address_lng, pfd.data_subcon_name,
pfd.fac_subcon_address_lat, pfd.fac_subcon_address_lng,
pfd.data_lat, pfd.fac_lat, pfd.data_ng, pfd.fac_lng,
fd.facility_id AS decl_facility_id,
fd.supplier_id AS decl_facility_supplier_id, fd.sub_supplier AS decl_facility_sub_supplier,
TRY_CONVERT(date, fd.create_ts) AS decl_facility_create_date, fd.company_id AS decl_facility_company_id,
fdm.preferrd_facility_id AS decl_preferrd_facility_id,
fdm.preferrd_facility_name AS decl_preferrd_facility_name,
fdm.reference_id AS decl_dedup_reference_id,
TRY_CONVERT(date, ds_sub.create_ts) AS decl_subcon_create_date,
n._id AS Child_Node,
n.derived_supplier_dec_ref AS node_derived_supplier_dec_ref,
n.data_supplier_default_ref AS node_data_supplier_default_ref,
n.supplier_dec_name AS node_supplier_dec_name
FROM dbo.dimscm_product_field_details_response pfd
INNER JOIN dbo.dimscm_product_node_response n
ON n.networkId = pfd.networkId
AND n.reference_code = pfd.product_node_response_ref
LEFT JOIN dbo.dimfacility_declaration fd
ON fd._id = pfd.derived_facility_dec_ref
AND fd.brand_context_id = pfd.brand_context_id
LEFT JOIN dbo.dim_compute_facility_dedup_mapping fdm
ON fdm.brand_context_id = fd.brand_context_id
AND fdm.duplicate_entities_entity_id = fd._id
LEFT JOIN dbo.dimsupplier_declaration ds_sub
ON ds_sub._id = pfd.Sub_supplier_declaration_ref
AND ds_sub.brand_context_id = pfd.brand_context_id
WHERE (pfd.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
AND (n.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
) AS _t) [numPartitions=1] (3)
+- == Initial Plan ==
DeserializeToObject (13)
+- Project (12)
+- Filter (11)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- AdaptiveSparkPlan (6)
+- Exchange (5)
+- Project (4)
+- Scan JDBCRelation((
SELECT
pfd._id, pfd.product_node_response_ref,
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
pfd.facility_declaration_ref, pfd.data_facility_dec_ref, pfd.derived_facility_dec_ref,
pfd.facility_name, pfd.data_facility_name,
pfd.fac_city, pfd.data_city, pfd.fac_state, pfd.data_state,
pfd.fac_country, pfd.data_country, pfd.fac_address_line1, pfd.data_address_line1,
pfd.enabled, pfd.facility_default_ref, pfd.Subcontractor_supplier_default_ref,
pfd.sub_contractor, pfd.facility_subcontartor, pfd.Sub_supplier_declaration_ref,
pfd.supplier_declaration_ref, pfd.Value_process, pfd.data_key_values, pfd.update_ts,
pfd.data_subcon_address_city, pfd.data_subcon_address_state, pfd.data_subcon_address_country,
pfd.data_subcon_address_lat, pfd.data_subcon_address_lng, pfd.data_subcon_name,
pfd.fac_subcon_address_lat, pfd.fac_subcon_address_lng,
pfd.data_lat, pfd.fac_lat, pfd.data_ng, pfd.fac_lng,
fd.facility_id AS decl_facility_id,
fd.supplier_id AS decl_facility_supplier_id, fd.sub_supplier AS decl_facility_sub_supplier,
TRY_CONVERT(date, fd.create_ts) AS decl_facility_create_date, fd.company_id AS decl_facility_company_id,
fdm.preferrd_facility_id AS decl_preferrd_facility_id,
fdm.preferrd_facility_name AS decl_preferrd_facility_name,
fdm.reference_id AS decl_dedup_reference_id,
TRY_CONVERT(date, ds_sub.create_ts) AS decl_subcon_create_date,
n._id AS Child_Node,
n.derived_supplier_dec_ref AS node_derived_supplier_dec_ref,
n.data_supplier_default_ref AS node_data_supplier_default_ref,
n.supplier_dec_name AS node_supplier_dec_name
FROM dbo.dimscm_product_field_details_response pfd
INNER JOIN dbo.dimscm_product_node_response n
ON n.networkId = pfd.networkId
AND n.reference_code = pfd.product_node_response_ref
LEFT JOIN dbo.dimfacility_declaration fd
ON fd._id = pfd.derived_facility_dec_ref
AND fd.brand_context_id = pfd.brand_context_id
LEFT JOIN dbo.dim_compute_facility_dedup_mapping fdm
ON fdm.brand_context_id = fd.brand_context_id
AND fdm.duplicate_entities_entity_id = fd._id
LEFT JOIN dbo.dimsupplier_declaration ds_sub
ON ds_sub._id = pfd.Sub_supplier_declaration_ref
AND ds_sub.brand_context_id = pfd.brand_context_id
WHERE (pfd.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
AND (n.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
) AS _t) [numPartitions=1] (3)
(1) InMemoryTableScan
Output [42]: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, is_unknown_supplier#10205920, launch_config_ref#10204982, product_node_response_ref#10204977, resolved_fac_address#10205388, resolved_fac_city#10205205, resolved_fac_country#10205326, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_fac_state#10205265, resolved_facility_name#10205146, resolved_facility_ref#10205088, resolved_sub_supplier_ref#10205646, resolved_subcontractor#10205580, resolved_supplier_ref#10205850, revision_version#10204983, update_ts#10205006]
Arguments: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, ... 18 more fields], [isnotnull(resolved_facility_ref#10205088)]
(2) InMemoryRelation
Arguments: [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, ... 46 more fields], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@7795a5ad,StorageLevel(disk, memory, deserialized, 1 replicas),AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
ShuffleQueryStage 0
+- Exchange hashpartitioning(brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, 5), REPARTITION_BY_NUM, [plan_id=349462]
+- *(1) Project [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, ... 46 more fields]
+- *(1) Scan JDBCRelation((
SELECT
pfd._id, pfd.product_node_response_ref,
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
pfd.facility_declaration_ref, pfd.data_facility_dec_ref, pfd.derived_facility_dec_ref,
pfd.facility_name, pfd.data_facility_name,
pfd.fac_city, pfd.data_city, pfd.fac_state, pfd.data_state,
pfd.fac_country, pfd.data_country, pfd.fac_address_line1, pfd.data_address_line1,
pfd.enabled, pfd.facility_default_ref, pfd.Subcontractor_supplier_default_ref,
pfd.sub_contractor, pfd.facility_subcontartor, pfd.Sub_supplier_declaration_ref,
pfd.supplier_declaration_ref, pfd.Value_process, pfd.data_key_values, pfd.update_ts,
pfd.data_subcon_address_city, pfd.data_subcon_address_state, pfd.data_subcon_address_country,
pfd.data_subcon_address_lat, pfd.data_subcon_address_lng, pfd.data_subcon_name,
pfd.fac_subcon_address_lat, pfd.fac_subcon_address_lng,
pfd.data_lat, pfd.fac_lat, pfd.data_ng, pfd.fac_lng,
fd.facility_id AS decl_facility_id,
fd.supplier_id AS decl_facility_supplier_id, fd.sub_supplier AS decl_facility_sub_supplier,
TRY_CONVERT(date, fd.create_ts) AS decl_facility_create_date, fd.company_id AS decl_facility_company_id,
fdm.preferrd_facility_id AS decl_preferrd_facility_id,
fdm.preferrd_facility_name AS decl_preferrd_facility_name,
fdm.reference_id AS decl_dedup_reference_id,
TRY_CONVERT(date, ds_sub.create_ts) AS decl_subcon_create_date,
n._id AS Child_Node,
n.derived_supplier_dec_ref AS node_derived_supplier_dec_ref,
n.data_supplier_default_ref AS node_data_supplier_default_ref,
n.supplier_dec_name AS node_supplier_dec_name
FROM dbo.dimscm_product_field_details_response pfd
INNER JOIN dbo.dimscm_product_node_response n
ON n.networkId = pfd.networkId
AND n.reference_code = pfd.product_node_response_ref
LEFT JOIN dbo.dimfacility_declaration fd
ON fd._id = pfd.derived_facility_dec_ref
AND fd.brand_context_id = pfd.brand_context_id
LEFT JOIN dbo.dim_compute_facility_dedup_mapping fdm
ON fdm.brand_context_id = fd.brand_context_id
AND fdm.duplicate_entities_entity_id = fd._id
LEFT JOIN dbo.dimsupplier_declaration ds_sub
ON ds_sub._id = pfd.Sub_supplier_declaration_ref
AND ds_sub.brand_context_id = pfd.brand_context_id
WHERE (pfd.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
AND (n.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
) AS _t) [numPartitions=1] [_id#10204976,product_node_response_ref#10204977,NetworkID#10204978,is_latest#10204979,brand_context_id#10204980,company_id#10204981,launch_config_ref#10204982,revision_version#10204983,facility_declaration_ref#10204984,data_facility_dec_ref#10204985,derived_facility_dec_ref#10204986,facility_name#10204987,data_facility_name#10204988,fac_city#10204989,data_city#10204990,fac_state#10204991,data_state#10204992,fac_country#10204993,data_country#10204994,fac_address_line1#10204995,data_address_line1#10204996,enabled#10204997,facility_default_ref#10204998,Subcontractor_supplier_default_ref#10204999,... 32 more fields] PushedFilters: [], ReadSchema: struct<_id:string,product_node_response_ref:string,NetworkID:string,is_latest:boolean,brand_conte...
+- == Initial Plan ==
Exchange hashpartitioning(brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, 5), REPARTITION_BY_NUM, [plan_id=349189]
+- Project [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, ... 46 more fields]
+- Scan JDBCRelation((
SELECT
pfd._id, pfd.product_node_response_ref,
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
pfd.facility_declaration_ref, pfd.data_facility_dec_ref, pfd.derived_facility_dec_ref,
pfd.facility_name, pfd.data_facility_name,
pfd.fac_city, pfd.data_city, pfd.fac_state, pfd.data_state,
pfd.fac_country, pfd.data_country, pfd.fac_address_line1, pfd.data_address_line1,
pfd.enabled, pfd.facility_default_ref, pfd.Subcontractor_supplier_default_ref,
pfd.sub_contractor, pfd.facility_subcontartor, pfd.Sub_supplier_declaration_ref,
pfd.supplier_declaration_ref, pfd.Value_process, pfd.data_key_values, pfd.update_ts,
pfd.data_subcon_address_city, pfd.data_subcon_address_state, pfd.data_subcon_address_country,
pfd.data_subcon_address_lat, pfd.data_subcon_address_lng, pfd.data_subcon_name,
pfd.fac_subcon_address_lat, pfd.fac_subcon_address_lng,
pfd.data_lat, pfd.fac_lat, pfd.data_ng, pfd.fac_lng,
fd.facility_id AS decl_facility_id,
fd.supplier_id AS decl_facility_supplier_id, fd.sub_supplier AS decl_facility_sub_supplier,
TRY_CONVERT(date, fd.create_ts) AS decl_facility_create_date, fd.company_id AS decl_facility_company_id,
fdm.preferrd_facility_id AS decl_preferrd_facility_id,
fdm.preferrd_facility_name AS decl_preferrd_facility_name,
fdm.reference_id AS decl_dedup_reference_id,
TRY_CONVERT(date, ds_sub.create_ts) AS decl_subcon_create_date,
n._id AS Child_Node,
n.derived_supplier_dec_ref AS node_derived_supplier_dec_ref,
n.data_supplier_default_ref AS node_data_supplier_default_ref,
n.supplier_dec_name AS node_supplier_dec_name
FROM dbo.dimscm_product_field_details_response pfd
INNER JOIN dbo.dimscm_product_node_response n
ON n.networkId = pfd.networkId
AND n.reference_code = pfd.product_node_response_ref
LEFT JOIN dbo.dimfacility_declaration fd
ON fd._id = pfd.derived_facility_dec_ref
AND fd.brand_context_id = pfd.brand_context_id
LEFT JOIN dbo.dim_compute_facility_dedup_mapping fdm
ON fdm.brand_context_id = fd.brand_context_id
AND fdm.duplicate_entities_entity_id = fd._id
LEFT JOIN dbo.dimsupplier_declaration ds_sub
ON ds_sub._id = pfd.Sub_supplier_declaration_ref
AND ds_sub.brand_context_id = pfd.brand_context_id
WHERE (pfd.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
AND (n.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
) AS _t) [numPartitions=1] [_id#10204976,product_node_response_ref#10204977,NetworkID#10204978,is_latest#10204979,brand_context_id#10204980,company_id#10204981,launch_config_ref#10204982,revision_version#10204983,facility_declaration_ref#10204984,data_facility_dec_ref#10204985,derived_facility_dec_ref#10204986,facility_name#10204987,data_facility_name#10204988,fac_city#10204989,data_city#10204990,fac_state#10204991,data_state#10204992,fac_country#10204993,data_country#10204994,fac_address_line1#10204995,data_address_line1#10204996,enabled#10204997,facility_default_ref#10204998,Subcontractor_supplier_default_ref#10204999,... 32 more fields] PushedFilters: [], ReadSchema: struct<_id:string,product_node_response_ref:string,NetworkID:string,is_latest:boolean,brand_conte...
,None)
(3) Scan JDBCRelation((
SELECT
pfd._id, pfd.product_node_response_ref,
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
pfd.facility_declaration_ref, pfd.data_facility_dec_ref, pfd.derived_facility_dec_ref,
pfd.facility_name, pfd.data_facility_name,
pfd.fac_city, pfd.data_city, pfd.fac_state, pfd.data_state,
pfd.fac_country, pfd.data_country, pfd.fac_address_line1, pfd.data_address_line1,
pfd.enabled, pfd.facility_default_ref, pfd.Subcontractor_supplier_default_ref,
pfd.sub_contractor, pfd.facility_subcontartor, pfd.Sub_supplier_declaration_ref,
pfd.supplier_declaration_ref, pfd.Value_process, pfd.data_key_values, pfd.update_ts,
pfd.data_subcon_address_city, pfd.data_subcon_address_state, pfd.data_subcon_address_country,
pfd.data_subcon_address_lat, pfd.data_subcon_address_lng, pfd.data_subcon_name,
pfd.fac_subcon_address_lat, pfd.fac_subcon_address_lng,
pfd.data_lat, pfd.fac_lat, pfd.data_ng, pfd.fac_lng,
fd.facility_id AS decl_facility_id,
fd.supplier_id AS decl_facility_supplier_id, fd.sub_supplier AS decl_facility_sub_supplier,
TRY_CONVERT(date, fd.create_ts) AS decl_facility_create_date, fd.company_id AS decl_facility_company_id,
fdm.preferrd_facility_id AS decl_preferrd_facility_id,
fdm.preferrd_facility_name AS decl_preferrd_facility_name,
fdm.reference_id AS decl_dedup_reference_id,
TRY_CONVERT(date, ds_sub.create_ts) AS decl_subcon_create_date,
n._id AS Child_Node,
n.derived_supplier_dec_ref AS node_derived_supplier_dec_ref,
n.data_supplier_default_ref AS node_data_supplier_default_ref,
n.supplier_dec_name AS node_supplier_dec_name
FROM dbo.dimscm_product_field_details_response pfd
INNER JOIN dbo.dimscm_product_node_response n
ON n.networkId = pfd.networkId
AND n.reference_code = pfd.product_node_response_ref
LEFT JOIN dbo.dimfacility_declaration fd
ON fd._id = pfd.derived_facility_dec_ref
AND fd.brand_context_id = pfd.brand_context_id
LEFT JOIN dbo.dim_compute_facility_dedup_mapping fdm
ON fdm.brand_context_id = fd.brand_context_id
AND fdm.duplicate_entities_entity_id = fd._id
LEFT JOIN dbo.dimsupplier_declaration ds_sub
ON ds_sub._id = pfd.Sub_supplier_declaration_ref
AND ds_sub.brand_context_id = pfd.brand_context_id
WHERE (pfd.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
AND (n.networkId IN ('FC6B9E30C555A9A125F54FB392C3F5E2E0634774B82994FBE2731FE1D0912898', 'FC7667F06366D246F301669B976189268D1841D57CEF30414299FEC6EC2B6629', 'FC80F6F4200AEA51D050CE73269C622C60A36B8615636AEADC031ECE7E1D98B4', 'FCA6C6859060C2CA4B3F71C1B88D4DC1CC2758BA40E62525BE6686F712CEE741', 'FCC3FC9CC329FFAFB05FA0603302F1746B8504A5A3C2A693859A6545367BBF87'))
) AS _t) [numPartitions=1]
Output [56]: [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, sub_contractor#10205000, facility_subcontartor#10205001, Sub_supplier_declaration_ref#10205002, supplier_declaration_ref#10205003, Value_process#10205004, data_key_values#10205005, update_ts#10205006, data_subcon_address_city#10205007, data_subcon_address_state#10205008, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_name#10205012, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, data_lat#10205015, fac_lat#10205016, data_ng#10205017, fac_lng#10205018, decl_facility_id#10205019, decl_facility_supplier_id#10205020, decl_facility_sub_supplier#10205021, decl_facility_create_date#10205022, decl_facility_company_id#10205023, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_dedup_reference_id#10205026, decl_subcon_create_date#10205027, Child_Node#10205028, node_derived_supplier_dec_ref#10205029, node_data_supplier_default_ref#10205030, node_supplier_dec_name#10205031]
ReadSchema: struct<_id:string,product_node_response_ref:string,NetworkID:string,is_latest:boolean,brand_context_id:string,company_id:string,launch_config_ref:string,revision_version:smallint,facility_declaration_ref:string,data_facility_dec_ref:string,derived_facility_dec_ref:string,facility_name:string,data_facility_name:string,fac_city:string,data_city:string,fac_state:string,data_state:string,fac_country:string,data_country:string,fac_address_line1:string,data_address_line1:string,enabled:boolean,facility_default_ref:string,Subcontractor_supplier_default_ref:string,sub_contractor:boolean,facility_subcontartor:string,Sub_supplier_declaration_ref:string,supplier_declaration_ref:string,Value_process:string,data_key_values:string,update_ts:timestamp,data_subcon_address_city:string,data_subcon_address_state:string,data_subcon_address_country:string,data_subcon_address_lat:string,data_subcon_address_lng:string,data_subcon_name:string,fac_subcon_address_lat:string,fac_subcon_address_lng:string,data_lat:double,fac_lat:string,data_ng:double,fac_lng:string,decl_facility_id:string,decl_facility_supplier_id:string,decl_facility_sub_supplier:boolean,decl_facility_create_date:date,decl_facility_company_id:string,decl_preferrd_facility_id:string,decl_preferrd_facility_name:string,decl_dedup_reference_id:string,decl_subcon_create_date:date,Child_Node:string,node_derived_supplier_dec_ref:string,node_data_supplier_default_ref:string,node_supplier_dec_name:string>
(4) Project
Output [70]: [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, sub_contractor#10205000, facility_subcontartor#10205001, Sub_supplier_declaration_ref#10205002, supplier_declaration_ref#10205003, Value_process#10205004, data_key_values#10205005, update_ts#10205006, data_subcon_address_city#10205007, data_subcon_address_state#10205008, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_name#10205012, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, data_lat#10205015, fac_lat#10205016, data_ng#10205017, fac_lng#10205018, decl_facility_id#10205019, decl_facility_supplier_id#10205020, decl_facility_sub_supplier#10205021, decl_facility_create_date#10205022, decl_facility_company_id#10205023, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_dedup_reference_id#10205026, decl_subcon_create_date#10205027, Child_Node#10205028, node_derived_supplier_dec_ref#10205029, node_data_supplier_default_ref#10205030, node_supplier_dec_name#10205031, coalesce(CASE WHEN (isnull(derived_facility_dec_ref#10204986) OR (derived_facility_dec_ref#10204986 = )) THEN null ELSE derived_facility_dec_ref#10204986 END, CASE WHEN (isnull(facility_default_ref#10204998) OR (facility_default_ref#10204998 = )) THEN null ELSE facility_default_ref#10204998 END) AS resolved_facility_ref#10205088, coalesce(CASE WHEN (isnull(data_facility_name#10204988) OR (data_facility_name#10204988 = )) THEN null ELSE data_facility_name#10204988 END, CASE WHEN (isnull(facility_name#10204987) OR (facility_name#10204987 = )) THEN null ELSE facility_name#10204987 END) AS resolved_facility_name#10205146, coalesce(CASE WHEN (isnull(data_city#10204990) OR (data_city#10204990 = )) THEN null ELSE data_city#10204990 END, CASE WHEN (isnull(fac_city#10204989) OR (fac_city#10204989 = )) THEN null ELSE fac_city#10204989 END) AS resolved_fac_city#10205205, coalesce(CASE WHEN (isnull(data_state#10204992) OR (data_state#10204992 = )) THEN null ELSE data_state#10204992 END, CASE WHEN (isnull(fac_state#10204991) OR (fac_state#10204991 = )) THEN null ELSE fac_state#10204991 END) AS resolved_fac_state#10205265, coalesce(CASE WHEN (isnull(data_country#10204994) OR (data_country#10204994 = )) THEN null ELSE data_country#10204994 END, CASE WHEN (isnull(fac_country#10204993) OR (fac_country#10204993 = )) THEN null ELSE fac_country#10204993 END) AS resolved_fac_country#10205326, coalesce(CASE WHEN (isnull(data_address_line1#10204996) OR (data_address_line1#10204996 = )) THEN null ELSE data_address_line1#10204996 END, CASE WHEN (isnull(fac_address_line1#10204995) OR (fac_address_line1#10204995 = )) THEN null ELSE fac_address_line1#10204995 END) AS resolved_fac_address#10205388, CASE WHEN isnotnull(data_lat#10205015) THEN cast(data_lat#10205015 as string) ELSE fac_lat#10205016 END AS resolved_fac_lat#10205451, CASE WHEN isnotnull(data_ng#10205017) THEN cast(data_ng#10205017 as string) ELSE fac_lng#10205018 END AS resolved_fac_lng#10205515, (coalesce(sub_contractor#10205000, false) OR coalesce((cast(facility_subcontartor#10205001 as int) = 1), false)) AS resolved_subcontractor#10205580, CASE WHEN (coalesce(sub_contractor#10205000, false) OR coalesce((cast(facility_subcontartor#10205001 as int) = 1), false)) THEN coalesce(CASE WHEN (isnull(Sub_supplier_declaration_ref#10205002) OR (Sub_supplier_declaration_ref#10205002 = )) THEN null ELSE Sub_supplier_declaration_ref#10205002 END, CASE WHEN (isnull(Subcontractor_supplier_default_ref#10204999) OR (Subcontractor_supplier_default_ref#10204999 = )) THEN null ELSE Subcontractor_supplier_default_ref#10204999 END) END AS resolved_sub_supplier_ref#10205646, ((isnull(data_facility_dec_ref#10204985) AND isnull(facility_declaration_ref#10204984)) AND coalesce((data_facility_name#10204988 = Facility Unknown), false)) AS is_unknown_facility#10205713, isnotnull(Subcontractor_supplier_default_ref#10204999) AS is_unknown_subcontractor#10205781, coalesce(CASE WHEN (isnull(node_derived_supplier_dec_ref#10205029) OR (node_derived_supplier_dec_ref#10205029 = )) THEN null ELSE node_derived_supplier_dec_ref#10205029 END, CASE WHEN (isnull(node_data_supplier_default_ref#10205030) OR (node_data_supplier_default_ref#10205030 = )) THEN null ELSE node_data_supplier_default_ref#10205030 END) AS resolved_supplier_ref#10205850, (isnull(node_derived_supplier_dec_ref#10205029) AND coalesce((node_supplier_dec_name#10205031 = Supplier Unknown), false)) AS is_unknown_supplier#10205920]
Input [56]: [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, sub_contractor#10205000, facility_subcontartor#10205001, Sub_supplier_declaration_ref#10205002, supplier_declaration_ref#10205003, Value_process#10205004, data_key_values#10205005, update_ts#10205006, data_subcon_address_city#10205007, data_subcon_address_state#10205008, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_name#10205012, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, data_lat#10205015, fac_lat#10205016, data_ng#10205017, fac_lng#10205018, decl_facility_id#10205019, decl_facility_supplier_id#10205020, decl_facility_sub_supplier#10205021, decl_facility_create_date#10205022, decl_facility_company_id#10205023, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_dedup_reference_id#10205026, decl_subcon_create_date#10205027, Child_Node#10205028, node_derived_supplier_dec_ref#10205029, node_data_supplier_default_ref#10205030, node_supplier_dec_name#10205031]
(5) Exchange
Input [70]: [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, sub_contractor#10205000, facility_subcontartor#10205001, Sub_supplier_declaration_ref#10205002, supplier_declaration_ref#10205003, Value_process#10205004, data_key_values#10205005, update_ts#10205006, data_subcon_address_city#10205007, data_subcon_address_state#10205008, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_name#10205012, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, data_lat#10205015, fac_lat#10205016, data_ng#10205017, fac_lng#10205018, decl_facility_id#10205019, decl_facility_supplier_id#10205020, decl_facility_sub_supplier#10205021, decl_facility_create_date#10205022, decl_facility_company_id#10205023, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_dedup_reference_id#10205026, decl_subcon_create_date#10205027, Child_Node#10205028, node_derived_supplier_dec_ref#10205029, node_data_supplier_default_ref#10205030, node_supplier_dec_name#10205031, resolved_facility_ref#10205088, resolved_facility_name#10205146, resolved_fac_city#10205205, resolved_fac_state#10205265, resolved_fac_country#10205326, resolved_fac_address#10205388, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_subcontractor#10205580, resolved_sub_supplier_ref#10205646, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, resolved_supplier_ref#10205850, is_unknown_supplier#10205920]
Arguments: hashpartitioning(brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, 5), REPARTITION_BY_NUM, [plan_id=349189]
(6) AdaptiveSparkPlan
Output [70]: [_id#10204976, product_node_response_ref#10204977, NetworkID#10204978, is_latest#10204979, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, facility_declaration_ref#10204984, data_facility_dec_ref#10204985, derived_facility_dec_ref#10204986, facility_name#10204987, data_facility_name#10204988, fac_city#10204989, data_city#10204990, fac_state#10204991, data_state#10204992, fac_country#10204993, data_country#10204994, fac_address_line1#10204995, data_address_line1#10204996, enabled#10204997, facility_default_ref#10204998, Subcontractor_supplier_default_ref#10204999, sub_contractor#10205000, facility_subcontartor#10205001, Sub_supplier_declaration_ref#10205002, supplier_declaration_ref#10205003, Value_process#10205004, data_key_values#10205005, update_ts#10205006, data_subcon_address_city#10205007, data_subcon_address_state#10205008, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_name#10205012, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, data_lat#10205015, fac_lat#10205016, data_ng#10205017, fac_lng#10205018, decl_facility_id#10205019, decl_facility_supplier_id#10205020, decl_facility_sub_supplier#10205021, decl_facility_create_date#10205022, decl_facility_company_id#10205023, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_dedup_reference_id#10205026, decl_subcon_create_date#10205027, Child_Node#10205028, node_derived_supplier_dec_ref#10205029, node_data_supplier_default_ref#10205030, node_supplier_dec_name#10205031, resolved_facility_ref#10205088, resolved_facility_name#10205146, resolved_fac_city#10205205, resolved_fac_state#10205265, resolved_fac_country#10205326, resolved_fac_address#10205388, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_subcontractor#10205580, resolved_sub_supplier_ref#10205646, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, resolved_supplier_ref#10205850, is_unknown_supplier#10205920]
Arguments: isFinalPlan=false
(7) TableCacheQueryStage
Output [42]: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, is_unknown_supplier#10205920, launch_config_ref#10204982, product_node_response_ref#10204977, resolved_fac_address#10205388, resolved_fac_city#10205205, resolved_fac_country#10205326, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_fac_state#10205265, resolved_facility_name#10205146, resolved_facility_ref#10205088, resolved_sub_supplier_ref#10205646, resolved_subcontractor#10205580, resolved_supplier_ref#10205850, revision_version#10204983, update_ts#10205006]
Arguments: 0
(8) Filter [codegen id : 1]
Input [42]: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, is_unknown_supplier#10205920, launch_config_ref#10204982, product_node_response_ref#10204977, resolved_fac_address#10205388, resolved_fac_city#10205205, resolved_fac_country#10205326, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_fac_state#10205265, resolved_facility_name#10205146, resolved_facility_ref#10205088, resolved_sub_supplier_ref#10205646, resolved_subcontractor#10205580, resolved_supplier_ref#10205850, revision_version#10204983, update_ts#10205006]
Condition : isnotnull(resolved_facility_ref#10205088)
(9) Project [codegen id : 1]
Output [41]: [NetworkID#10204978, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, Child_Node#10205028, is_latest#10204979, false AS is_latest_submitted#10210060, resolved_facility_ref#10205088 AS facility_declaration_RefID#10210061, resolved_supplier_ref#10205850 AS Supplier_declaration_RefID#10210062, product_node_response_ref#10204977 AS reference_code#10210063, _id#10204976 AS facdec_Id#10210064, resolved_facility_name#10205146 AS FacilityName#10210065, resolved_fac_city#10205205 AS FacilityCity#10210066, resolved_fac_state#10205265 AS FacilityState#10210067, resolved_fac_country#10205326 AS FacilityCountry#10210068, resolved_fac_address#10205388 AS FacilityAddress#10210069, enabled#10204997 AS fac_enabled#10210070, resolved_subcontractor#10205580 AS facility_Subcontractor#10210071, resolved_sub_supplier_ref#10205646 AS Sub_supplier_declaration_ref#10210072, decl_facility_id#10205019 AS facility_id#10210073, decl_facility_create_date#10205022 AS facility_first_created_date#10210074, CASE WHEN isnotnull(resolved_sub_supplier_ref#10205646) THEN decl_subcon_create_date#10205027 END AS subcontractor_first_created_date#10210075, decl_facility_company_id#10205023 AS facility_declared_company#10210076, decl_preferrd_facility_id#10205024 AS preferrd_facility_id#10210077, decl_preferrd_facility_name#10205025 AS preferrd_facility_name#10210078, decl_dedup_reference_id#10205026 AS dedup_reference_id#10210079, data_subcon_address_city#10205007 AS subcontractor_city#10210080, data_subcon_address_state#10205008 AS subcontractor_state#10210081, data_subcon_address_country#10205009 AS subcontractor_country#10210082, coalesce(data_subcon_address_lat#10205010, fac_subcon_address_lat#10205013) AS subcontractor_address_lat#10210083, coalesce(data_subcon_address_lng#10205011, fac_subcon_address_lng#10205014) AS subcontractor_address_lng#10210084, data_subcon_name#10205012 AS subcontractor_name#10210085, update_ts#10205006 AS node_update_ts#10210086, is_unknown_facility#10205713, is_unknown_supplier#10205920, is_unknown_subcontractor#10205781, CASE WHEN (isnotnull(decl_facility_supplier_id#10205020) AND coalesce(NOT decl_facility_sub_supplier#10205021, false)) THEN Direct ELSE InDirect END AS DirectOrIndirectFacility#10210087, resolved_fac_lat#10205451 AS FacilityLat#10210088, resolved_fac_lng#10205515 AS FacilityLng#10210089, 2026-10-16 07:30:22.066784 AS update_ts#10210090]
Input [42]: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, is_unknown_supplier#10205920, launch_config_ref#10204982, product_node_response_ref#10204977, resolved_fac_address#10205388, resolved_fac_city#10205205, resolved_fac_country#10205326, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_fac_state#10205265, resolved_facility_name#10205146, resolved_facility_ref#10205088, resolved_sub_supplier_ref#10205646, resolved_subcontractor#10205580, resolved_supplier_ref#10205850, revision_version#10204983, update_ts#10205006]
(10) DeserializeToObject
Input [41]: [NetworkID#10204978, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, Child_Node#10205028, is_latest#10204979, is_latest_submitted#10210060, facility_declaration_RefID#10210061, Supplier_declaration_RefID#10210062, reference_code#10210063, facdec_Id#10210064, FacilityName#10210065, FacilityCity#10210066, FacilityState#10210067, FacilityCountry#10210068, FacilityAddress#10210069, fac_enabled#10210070, facility_Subcontractor#10210071, Sub_supplier_declaration_ref#10210072, facility_id#10210073, facility_first_created_date#10210074, subcontractor_first_created_date#10210075, facility_declared_company#10210076, preferrd_facility_id#10210077, preferrd_facility_name#10210078, dedup_reference_id#10210079, subcontractor_city#10210080, subcontractor_state#10210081, subcontractor_country#10210082, subcontractor_address_lat#10210083, subcontractor_address_lng#10210084, subcontractor_name#10210085, node_update_ts#10210086, is_unknown_facility#10205713, is_unknown_supplier#10205920, is_unknown_subcontractor#10205781, DirectOrIndirectFacility#10210087, FacilityLat#10210088, FacilityLng#10210089, update_ts#10210090]
Arguments: createexternalrow(NetworkID#10204978.toString, brand_context_id#10204980.toString, company_id#10204981.toString, launch_config_ref#10204982.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#10204983, true, false, true), Child_Node#10205028.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#10204979, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#10210060, true, false, true), facility_declaration_RefID#10210061.toString, Supplier_declaration_RefID#10210062.toString, reference_code#10210063.toString, facdec_Id#10210064.toString, FacilityName#10210065.toString, FacilityCity#10210066.toString, FacilityState#10210067.toString, FacilityCountry#10210068.toString, FacilityAddress#10210069.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, fac_enabled#10210070, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, facility_Subcontractor#10210071, true, false, true), Sub_supplier_declaration_ref#10210072.toString, facility_id#10210073.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, facility_first_created_date#10210074, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, subcontractor_first_created_date#10210075, true, false, true), facility_declared_company#10210076.toString, ... 58 more fields), obj#10215429: org.apache.spark.sql.Row
(11) Filter
Input [42]: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, is_unknown_supplier#10205920, launch_config_ref#10204982, product_node_response_ref#10204977, resolved_fac_address#10205388, resolved_fac_city#10205205, resolved_fac_country#10205326, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_fac_state#10205265, resolved_facility_name#10205146, resolved_facility_ref#10205088, resolved_sub_supplier_ref#10205646, resolved_subcontractor#10205580, resolved_supplier_ref#10205850, revision_version#10204983, update_ts#10205006]
Condition : isnotnull(resolved_facility_ref#10205088)
(12) Project
Output [41]: [NetworkID#10204978, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, Child_Node#10205028, is_latest#10204979, false AS is_latest_submitted#10210060, resolved_facility_ref#10205088 AS facility_declaration_RefID#10210061, resolved_supplier_ref#10205850 AS Supplier_declaration_RefID#10210062, product_node_response_ref#10204977 AS reference_code#10210063, _id#10204976 AS facdec_Id#10210064, resolved_facility_name#10205146 AS FacilityName#10210065, resolved_fac_city#10205205 AS FacilityCity#10210066, resolved_fac_state#10205265 AS FacilityState#10210067, resolved_fac_country#10205326 AS FacilityCountry#10210068, resolved_fac_address#10205388 AS FacilityAddress#10210069, enabled#10204997 AS fac_enabled#10210070, resolved_subcontractor#10205580 AS facility_Subcontractor#10210071, resolved_sub_supplier_ref#10205646 AS Sub_supplier_declaration_ref#10210072, decl_facility_id#10205019 AS facility_id#10210073, decl_facility_create_date#10205022 AS facility_first_created_date#10210074, CASE WHEN isnotnull(resolved_sub_supplier_ref#10205646) THEN decl_subcon_create_date#10205027 END AS subcontractor_first_created_date#10210075, decl_facility_company_id#10205023 AS facility_declared_company#10210076, decl_preferrd_facility_id#10205024 AS preferrd_facility_id#10210077, decl_preferrd_facility_name#10205025 AS preferrd_facility_name#10210078, decl_dedup_reference_id#10205026 AS dedup_reference_id#10210079, data_subcon_address_city#10205007 AS subcontractor_city#10210080, data_subcon_address_state#10205008 AS subcontractor_state#10210081, data_subcon_address_country#10205009 AS subcontractor_country#10210082, coalesce(data_subcon_address_lat#10205010, fac_subcon_address_lat#10205013) AS subcontractor_address_lat#10210083, coalesce(data_subcon_address_lng#10205011, fac_subcon_address_lng#10205014) AS subcontractor_address_lng#10210084, data_subcon_name#10205012 AS subcontractor_name#10210085, update_ts#10205006 AS node_update_ts#10210086, is_unknown_facility#10205713, is_unknown_supplier#10205920, is_unknown_subcontractor#10205781, CASE WHEN (isnotnull(decl_facility_supplier_id#10205020) AND coalesce(NOT decl_facility_sub_supplier#10205021, false)) THEN Direct ELSE InDirect END AS DirectOrIndirectFacility#10210087, resolved_fac_lat#10205451 AS FacilityLat#10210088, resolved_fac_lng#10205515 AS FacilityLng#10210089, 2026-10-16 07:30:22.066784 AS update_ts#10210090]
Input [42]: [Child_Node#10205028, NetworkID#10204978, _id#10204976, brand_context_id#10204980, company_id#10204981, data_subcon_address_city#10205007, data_subcon_address_country#10205009, data_subcon_address_lat#10205010, data_subcon_address_lng#10205011, data_subcon_address_state#10205008, data_subcon_name#10205012, decl_dedup_reference_id#10205026, decl_facility_company_id#10205023, decl_facility_create_date#10205022, decl_facility_id#10205019, decl_facility_sub_supplier#10205021, decl_facility_supplier_id#10205020, decl_preferrd_facility_id#10205024, decl_preferrd_facility_name#10205025, decl_subcon_create_date#10205027, enabled#10204997, fac_subcon_address_lat#10205013, fac_subcon_address_lng#10205014, is_latest#10204979, is_unknown_facility#10205713, is_unknown_subcontractor#10205781, is_unknown_supplier#10205920, launch_config_ref#10204982, product_node_response_ref#10204977, resolved_fac_address#10205388, resolved_fac_city#10205205, resolved_fac_country#10205326, resolved_fac_lat#10205451, resolved_fac_lng#10205515, resolved_fac_state#10205265, resolved_facility_name#10205146, resolved_facility_ref#10205088, resolved_sub_supplier_ref#10205646, resolved_subcontractor#10205580, resolved_supplier_ref#10205850, revision_version#10204983, update_ts#10205006]
(13) DeserializeToObject
Input [41]: [NetworkID#10204978, brand_context_id#10204980, company_id#10204981, launch_config_ref#10204982, revision_version#10204983, Child_Node#10205028, is_latest#10204979, is_latest_submitted#10210060, facility_declaration_RefID#10210061, Supplier_declaration_RefID#10210062, reference_code#10210063, facdec_Id#10210064, FacilityName#10210065, FacilityCity#10210066, FacilityState#10210067, FacilityCountry#10210068, FacilityAddress#10210069, fac_enabled#10210070, facility_Subcontractor#10210071, Sub_supplier_declaration_ref#10210072, facility_id#10210073, facility_first_created_date#10210074, subcontractor_first_created_date#10210075, facility_declared_company#10210076, preferrd_facility_id#10210077, preferrd_facility_name#10210078, dedup_reference_id#10210079, subcontractor_city#10210080, subcontractor_state#10210081, subcontractor_country#10210082, subcontractor_address_lat#10210083, subcontractor_address_lng#10210084, subcontractor_name#10210085, node_update_ts#10210086, is_unknown_facility#10205713, is_unknown_supplier#10205920, is_unknown_subcontractor#10205781, DirectOrIndirectFacility#10210087, FacilityLat#10210088, FacilityLng#10210089, update_ts#10210090]
Arguments: createexternalrow(NetworkID#10204978.toString, brand_context_id#10204980.toString, company_id#10204981.toString, launch_config_ref#10204982.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#10204983, true, false, true), Child_Node#10205028.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#10204979, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#10210060, true, false, true), facility_declaration_RefID#10210061.toString, Supplier_declaration_RefID#10210062.toString, reference_code#10210063.toString, facdec_Id#10210064.toString, FacilityName#10210065.toString, FacilityCity#10210066.toString, FacilityState#10210067.toString, FacilityCountry#10210068.toString, FacilityAddress#10210069.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, fac_enabled#10210070, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, facility_Subcontractor#10210071, true, false, true), Sub_supplier_declaration_ref#10210072.toString, facility_id#10210073.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, facility_first_created_date#10210074, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, subcontractor_first_created_date#10210075, true, false, true), facility_declared_company#10210076.toString, ... 58 more fields), obj#10215429: org.apache.spark.sql.Row
(14) AdaptiveSparkPlan
Output [1]: [obj#10215429]
Arguments: isFinalPlan=true