== Physical Plan ==
AdaptiveSparkPlan (14)
+- == Final Plan ==
DeserializeToObject (10)
+- * Project (9)
+- * Filter (8)
+- TableCacheQueryStage (7), Statistics(sizeInBytes=135.5 KiB, rowCount=223)
+- 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 ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
AND (n.networkId IN ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
) 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 ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
AND (n.networkId IN ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
) AS _t) [numPartitions=1] (3)
(1) InMemoryTableScan
Output [42]: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, is_unknown_facility#743231, is_unknown_subcontractor#743310, is_unknown_supplier#743482, launch_config_ref#735747, product_node_response_ref#735742, resolved_fac_address#739630, resolved_fac_city#736908, resolved_fac_country#738562, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_fac_state#736972, resolved_facility_name#736475, resolved_facility_ref#736035, resolved_sub_supplier_ref#742771, resolved_subcontractor#742430, resolved_supplier_ref#743389, revision_version#735748, update_ts#735771]
Arguments: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, ... 18 more fields], [isnotnull(resolved_facility_ref#736035)]
(2) InMemoryRelation
Arguments: [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, ... 46 more fields], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@730ae8bf,StorageLevel(disk, memory, deserialized, 1 replicas),AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
ShuffleQueryStage 0
+- Exchange hashpartitioning(brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, 5), REPARTITION_BY_NUM, [plan_id=38734]
+- *(1) Project [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, ... 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 ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
AND (n.networkId IN ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
) AS _t) [numPartitions=1] [_id#735741,product_node_response_ref#735742,NetworkID#735743,is_latest#735744,brand_context_id#735745,company_id#735746,launch_config_ref#735747,revision_version#735748,facility_declaration_ref#735749,data_facility_dec_ref#735750,derived_facility_dec_ref#735751,facility_name#735752,data_facility_name#735753,fac_city#735754,data_city#735755,fac_state#735756,data_state#735757,fac_country#735758,data_country#735759,fac_address_line1#735760,data_address_line1#735761,enabled#735762,facility_default_ref#735763,Subcontractor_supplier_default_ref#735764,... 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#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, 5), REPARTITION_BY_NUM, [plan_id=37139]
+- Project [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, ... 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 ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
AND (n.networkId IN ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
) AS _t) [numPartitions=1] [_id#735741,product_node_response_ref#735742,NetworkID#735743,is_latest#735744,brand_context_id#735745,company_id#735746,launch_config_ref#735747,revision_version#735748,facility_declaration_ref#735749,data_facility_dec_ref#735750,derived_facility_dec_ref#735751,facility_name#735752,data_facility_name#735753,fac_city#735754,data_city#735755,fac_state#735756,data_state#735757,fac_country#735758,data_country#735759,fac_address_line1#735760,data_address_line1#735761,enabled#735762,facility_default_ref#735763,Subcontractor_supplier_default_ref#735764,... 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 ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
AND (n.networkId IN ('CA8B6C9470F32B632DA7BA4B4C9FC795772E7C5C1AE063F783BC08ECD8FC02FB', 'CC199D7AD02E89F76C81042A317B7A6C4F5A4BCBB79E443A20D92DEB38F51120', 'CE1D94CACE4C55E1F5810451A027029BC8A52DAA021EE59122896DDC646B7B1A', 'DADBBD0F84D845CAD7CD1D4782D62BA28CC5CA6C295EC56F03A1F9B8378B65A0', 'E0433DCF670BC83D900DC8E313EDBBB828A612E0447BC30ADB339966B3B65AC8'))
) AS _t) [numPartitions=1]
Output [56]: [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, sub_contractor#735765, facility_subcontartor#735766, Sub_supplier_declaration_ref#735767, supplier_declaration_ref#735768, Value_process#735769, data_key_values#735770, update_ts#735771, data_subcon_address_city#735772, data_subcon_address_state#735773, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_name#735777, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, data_lat#735780, fac_lat#735781, data_ng#735782, fac_lng#735783, decl_facility_id#735784, decl_facility_supplier_id#735785, decl_facility_sub_supplier#735786, decl_facility_create_date#735787, decl_facility_company_id#735788, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_dedup_reference_id#735791, decl_subcon_create_date#735792, Child_Node#735793, node_derived_supplier_dec_ref#735794, node_data_supplier_default_ref#735795, node_supplier_dec_name#735796]
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#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, sub_contractor#735765, facility_subcontartor#735766, Sub_supplier_declaration_ref#735767, supplier_declaration_ref#735768, Value_process#735769, data_key_values#735770, update_ts#735771, data_subcon_address_city#735772, data_subcon_address_state#735773, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_name#735777, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, data_lat#735780, fac_lat#735781, data_ng#735782, fac_lng#735783, decl_facility_id#735784, decl_facility_supplier_id#735785, decl_facility_sub_supplier#735786, decl_facility_create_date#735787, decl_facility_company_id#735788, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_dedup_reference_id#735791, decl_subcon_create_date#735792, Child_Node#735793, node_derived_supplier_dec_ref#735794, node_data_supplier_default_ref#735795, node_supplier_dec_name#735796, coalesce(CASE WHEN (isnull(derived_facility_dec_ref#735751) OR (derived_facility_dec_ref#735751 = )) THEN null ELSE derived_facility_dec_ref#735751 END, CASE WHEN (isnull(facility_default_ref#735763) OR (facility_default_ref#735763 = )) THEN null ELSE facility_default_ref#735763 END) AS resolved_facility_ref#736035, coalesce(CASE WHEN (isnull(data_facility_name#735753) OR (data_facility_name#735753 = )) THEN null ELSE data_facility_name#735753 END, CASE WHEN (isnull(facility_name#735752) OR (facility_name#735752 = )) THEN null ELSE facility_name#735752 END) AS resolved_facility_name#736475, coalesce(CASE WHEN (isnull(data_city#735755) OR (data_city#735755 = )) THEN null ELSE data_city#735755 END, CASE WHEN (isnull(fac_city#735754) OR (fac_city#735754 = )) THEN null ELSE fac_city#735754 END) AS resolved_fac_city#736908, coalesce(CASE WHEN (isnull(data_state#735757) OR (data_state#735757 = )) THEN null ELSE data_state#735757 END, CASE WHEN (isnull(fac_state#735756) OR (fac_state#735756 = )) THEN null ELSE fac_state#735756 END) AS resolved_fac_state#736972, coalesce(CASE WHEN (isnull(data_country#735759) OR (data_country#735759 = )) THEN null ELSE data_country#735759 END, CASE WHEN (isnull(fac_country#735758) OR (fac_country#735758 = )) THEN null ELSE fac_country#735758 END) AS resolved_fac_country#738562, coalesce(CASE WHEN (isnull(data_address_line1#735761) OR (data_address_line1#735761 = )) THEN null ELSE data_address_line1#735761 END, CASE WHEN (isnull(fac_address_line1#735760) OR (fac_address_line1#735760 = )) THEN null ELSE fac_address_line1#735760 END) AS resolved_fac_address#739630, CASE WHEN isnotnull(data_lat#735780) THEN cast(data_lat#735780 as string) ELSE fac_lat#735781 END AS resolved_fac_lat#740043, CASE WHEN isnotnull(data_ng#735782) THEN cast(data_ng#735782 as string) ELSE fac_lng#735783 END AS resolved_fac_lng#740162, (coalesce(sub_contractor#735765, false) OR coalesce((cast(facility_subcontartor#735766 as int) = 1), false)) AS resolved_subcontractor#742430, CASE WHEN (coalesce(sub_contractor#735765, false) OR coalesce((cast(facility_subcontartor#735766 as int) = 1), false)) THEN coalesce(CASE WHEN (isnull(Sub_supplier_declaration_ref#735767) OR (Sub_supplier_declaration_ref#735767 = )) THEN null ELSE Sub_supplier_declaration_ref#735767 END, CASE WHEN (isnull(Subcontractor_supplier_default_ref#735764) OR (Subcontractor_supplier_default_ref#735764 = )) THEN null ELSE Subcontractor_supplier_default_ref#735764 END) END AS resolved_sub_supplier_ref#742771, ((isnull(data_facility_dec_ref#735750) AND isnull(facility_declaration_ref#735749)) AND coalesce((data_facility_name#735753 = Facility Unknown), false)) AS is_unknown_facility#743231, isnotnull(Subcontractor_supplier_default_ref#735764) AS is_unknown_subcontractor#743310, coalesce(CASE WHEN (isnull(node_derived_supplier_dec_ref#735794) OR (node_derived_supplier_dec_ref#735794 = )) THEN null ELSE node_derived_supplier_dec_ref#735794 END, CASE WHEN (isnull(node_data_supplier_default_ref#735795) OR (node_data_supplier_default_ref#735795 = )) THEN null ELSE node_data_supplier_default_ref#735795 END) AS resolved_supplier_ref#743389, (isnull(node_derived_supplier_dec_ref#735794) AND coalesce((node_supplier_dec_name#735796 = Supplier Unknown), false)) AS is_unknown_supplier#743482]
Input [56]: [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, sub_contractor#735765, facility_subcontartor#735766, Sub_supplier_declaration_ref#735767, supplier_declaration_ref#735768, Value_process#735769, data_key_values#735770, update_ts#735771, data_subcon_address_city#735772, data_subcon_address_state#735773, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_name#735777, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, data_lat#735780, fac_lat#735781, data_ng#735782, fac_lng#735783, decl_facility_id#735784, decl_facility_supplier_id#735785, decl_facility_sub_supplier#735786, decl_facility_create_date#735787, decl_facility_company_id#735788, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_dedup_reference_id#735791, decl_subcon_create_date#735792, Child_Node#735793, node_derived_supplier_dec_ref#735794, node_data_supplier_default_ref#735795, node_supplier_dec_name#735796]
(5) Exchange
Input [70]: [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, sub_contractor#735765, facility_subcontartor#735766, Sub_supplier_declaration_ref#735767, supplier_declaration_ref#735768, Value_process#735769, data_key_values#735770, update_ts#735771, data_subcon_address_city#735772, data_subcon_address_state#735773, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_name#735777, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, data_lat#735780, fac_lat#735781, data_ng#735782, fac_lng#735783, decl_facility_id#735784, decl_facility_supplier_id#735785, decl_facility_sub_supplier#735786, decl_facility_create_date#735787, decl_facility_company_id#735788, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_dedup_reference_id#735791, decl_subcon_create_date#735792, Child_Node#735793, node_derived_supplier_dec_ref#735794, node_data_supplier_default_ref#735795, node_supplier_dec_name#735796, resolved_facility_ref#736035, resolved_facility_name#736475, resolved_fac_city#736908, resolved_fac_state#736972, resolved_fac_country#738562, resolved_fac_address#739630, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_subcontractor#742430, resolved_sub_supplier_ref#742771, is_unknown_facility#743231, is_unknown_subcontractor#743310, resolved_supplier_ref#743389, is_unknown_supplier#743482]
Arguments: hashpartitioning(brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, 5), REPARTITION_BY_NUM, [plan_id=37139]
(6) AdaptiveSparkPlan
Output [70]: [_id#735741, product_node_response_ref#735742, NetworkID#735743, is_latest#735744, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, facility_declaration_ref#735749, data_facility_dec_ref#735750, derived_facility_dec_ref#735751, facility_name#735752, data_facility_name#735753, fac_city#735754, data_city#735755, fac_state#735756, data_state#735757, fac_country#735758, data_country#735759, fac_address_line1#735760, data_address_line1#735761, enabled#735762, facility_default_ref#735763, Subcontractor_supplier_default_ref#735764, sub_contractor#735765, facility_subcontartor#735766, Sub_supplier_declaration_ref#735767, supplier_declaration_ref#735768, Value_process#735769, data_key_values#735770, update_ts#735771, data_subcon_address_city#735772, data_subcon_address_state#735773, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_name#735777, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, data_lat#735780, fac_lat#735781, data_ng#735782, fac_lng#735783, decl_facility_id#735784, decl_facility_supplier_id#735785, decl_facility_sub_supplier#735786, decl_facility_create_date#735787, decl_facility_company_id#735788, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_dedup_reference_id#735791, decl_subcon_create_date#735792, Child_Node#735793, node_derived_supplier_dec_ref#735794, node_data_supplier_default_ref#735795, node_supplier_dec_name#735796, resolved_facility_ref#736035, resolved_facility_name#736475, resolved_fac_city#736908, resolved_fac_state#736972, resolved_fac_country#738562, resolved_fac_address#739630, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_subcontractor#742430, resolved_sub_supplier_ref#742771, is_unknown_facility#743231, is_unknown_subcontractor#743310, resolved_supplier_ref#743389, is_unknown_supplier#743482]
Arguments: isFinalPlan=false
(7) TableCacheQueryStage
Output [42]: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, is_unknown_facility#743231, is_unknown_subcontractor#743310, is_unknown_supplier#743482, launch_config_ref#735747, product_node_response_ref#735742, resolved_fac_address#739630, resolved_fac_city#736908, resolved_fac_country#738562, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_fac_state#736972, resolved_facility_name#736475, resolved_facility_ref#736035, resolved_sub_supplier_ref#742771, resolved_subcontractor#742430, resolved_supplier_ref#743389, revision_version#735748, update_ts#735771]
Arguments: 0
(8) Filter [codegen id : 1]
Input [42]: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, is_unknown_facility#743231, is_unknown_subcontractor#743310, is_unknown_supplier#743482, launch_config_ref#735747, product_node_response_ref#735742, resolved_fac_address#739630, resolved_fac_city#736908, resolved_fac_country#738562, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_fac_state#736972, resolved_facility_name#736475, resolved_facility_ref#736035, resolved_sub_supplier_ref#742771, resolved_subcontractor#742430, resolved_supplier_ref#743389, revision_version#735748, update_ts#735771]
Condition : isnotnull(resolved_facility_ref#736035)
(9) Project [codegen id : 1]
Output [41]: [NetworkID#735743, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, Child_Node#735793, is_latest#735744, false AS is_latest_submitted#753716, resolved_facility_ref#736035 AS facility_declaration_RefID#753717, resolved_supplier_ref#743389 AS Supplier_declaration_RefID#753718, product_node_response_ref#735742 AS reference_code#753719, _id#735741 AS facdec_Id#753720, resolved_facility_name#736475 AS FacilityName#753721, resolved_fac_city#736908 AS FacilityCity#753722, resolved_fac_state#736972 AS FacilityState#753723, resolved_fac_country#738562 AS FacilityCountry#753724, resolved_fac_address#739630 AS FacilityAddress#753725, enabled#735762 AS fac_enabled#753726, resolved_subcontractor#742430 AS facility_Subcontractor#753727, resolved_sub_supplier_ref#742771 AS Sub_supplier_declaration_ref#753728, decl_facility_id#735784 AS facility_id#753729, decl_facility_create_date#735787 AS facility_first_created_date#753730, CASE WHEN isnotnull(resolved_sub_supplier_ref#742771) THEN decl_subcon_create_date#735792 END AS subcontractor_first_created_date#753731, decl_facility_company_id#735788 AS facility_declared_company#753732, decl_preferrd_facility_id#735789 AS preferrd_facility_id#753733, decl_preferrd_facility_name#735790 AS preferrd_facility_name#753734, decl_dedup_reference_id#735791 AS dedup_reference_id#753735, data_subcon_address_city#735772 AS subcontractor_city#753736, data_subcon_address_state#735773 AS subcontractor_state#753737, data_subcon_address_country#735774 AS subcontractor_country#753738, coalesce(data_subcon_address_lat#735775, fac_subcon_address_lat#735778) AS subcontractor_address_lat#753739, coalesce(data_subcon_address_lng#735776, fac_subcon_address_lng#735779) AS subcontractor_address_lng#753740, data_subcon_name#735777 AS subcontractor_name#753741, update_ts#735771 AS node_update_ts#753742, is_unknown_facility#743231, is_unknown_supplier#743482, is_unknown_subcontractor#743310, CASE WHEN (isnotnull(decl_facility_supplier_id#735785) AND coalesce(NOT decl_facility_sub_supplier#735786, false)) THEN Direct ELSE InDirect END AS DirectOrIndirectFacility#753743, resolved_fac_lat#740043 AS FacilityLat#753744, resolved_fac_lng#740162 AS FacilityLng#753745, 2026-10-17 07:30:07.102976 AS update_ts#753788]
Input [42]: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, is_unknown_facility#743231, is_unknown_subcontractor#743310, is_unknown_supplier#743482, launch_config_ref#735747, product_node_response_ref#735742, resolved_fac_address#739630, resolved_fac_city#736908, resolved_fac_country#738562, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_fac_state#736972, resolved_facility_name#736475, resolved_facility_ref#736035, resolved_sub_supplier_ref#742771, resolved_subcontractor#742430, resolved_supplier_ref#743389, revision_version#735748, update_ts#735771]
(10) DeserializeToObject
Input [41]: [NetworkID#735743, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, Child_Node#735793, is_latest#735744, is_latest_submitted#753716, facility_declaration_RefID#753717, Supplier_declaration_RefID#753718, reference_code#753719, facdec_Id#753720, FacilityName#753721, FacilityCity#753722, FacilityState#753723, FacilityCountry#753724, FacilityAddress#753725, fac_enabled#753726, facility_Subcontractor#753727, Sub_supplier_declaration_ref#753728, facility_id#753729, facility_first_created_date#753730, subcontractor_first_created_date#753731, facility_declared_company#753732, preferrd_facility_id#753733, preferrd_facility_name#753734, dedup_reference_id#753735, subcontractor_city#753736, subcontractor_state#753737, subcontractor_country#753738, subcontractor_address_lat#753739, subcontractor_address_lng#753740, subcontractor_name#753741, node_update_ts#753742, is_unknown_facility#743231, is_unknown_supplier#743482, is_unknown_subcontractor#743310, DirectOrIndirectFacility#753743, FacilityLat#753744, FacilityLng#753745, update_ts#753788]
Arguments: createexternalrow(NetworkID#735743.toString, brand_context_id#735745.toString, company_id#735746.toString, launch_config_ref#735747.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#735748, true, false, true), Child_Node#735793.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#735744, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#753716, true, false, true), facility_declaration_RefID#753717.toString, Supplier_declaration_RefID#753718.toString, reference_code#753719.toString, facdec_Id#753720.toString, FacilityName#753721.toString, FacilityCity#753722.toString, FacilityState#753723.toString, FacilityCountry#753724.toString, FacilityAddress#753725.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, fac_enabled#753726, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, facility_Subcontractor#753727, true, false, true), Sub_supplier_declaration_ref#753728.toString, facility_id#753729.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, facility_first_created_date#753730, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, subcontractor_first_created_date#753731, true, false, true), facility_declared_company#753732.toString, ... 58 more fields), obj#803904: org.apache.spark.sql.Row
(11) Filter
Input [42]: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, is_unknown_facility#743231, is_unknown_subcontractor#743310, is_unknown_supplier#743482, launch_config_ref#735747, product_node_response_ref#735742, resolved_fac_address#739630, resolved_fac_city#736908, resolved_fac_country#738562, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_fac_state#736972, resolved_facility_name#736475, resolved_facility_ref#736035, resolved_sub_supplier_ref#742771, resolved_subcontractor#742430, resolved_supplier_ref#743389, revision_version#735748, update_ts#735771]
Condition : isnotnull(resolved_facility_ref#736035)
(12) Project
Output [41]: [NetworkID#735743, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, Child_Node#735793, is_latest#735744, false AS is_latest_submitted#753716, resolved_facility_ref#736035 AS facility_declaration_RefID#753717, resolved_supplier_ref#743389 AS Supplier_declaration_RefID#753718, product_node_response_ref#735742 AS reference_code#753719, _id#735741 AS facdec_Id#753720, resolved_facility_name#736475 AS FacilityName#753721, resolved_fac_city#736908 AS FacilityCity#753722, resolved_fac_state#736972 AS FacilityState#753723, resolved_fac_country#738562 AS FacilityCountry#753724, resolved_fac_address#739630 AS FacilityAddress#753725, enabled#735762 AS fac_enabled#753726, resolved_subcontractor#742430 AS facility_Subcontractor#753727, resolved_sub_supplier_ref#742771 AS Sub_supplier_declaration_ref#753728, decl_facility_id#735784 AS facility_id#753729, decl_facility_create_date#735787 AS facility_first_created_date#753730, CASE WHEN isnotnull(resolved_sub_supplier_ref#742771) THEN decl_subcon_create_date#735792 END AS subcontractor_first_created_date#753731, decl_facility_company_id#735788 AS facility_declared_company#753732, decl_preferrd_facility_id#735789 AS preferrd_facility_id#753733, decl_preferrd_facility_name#735790 AS preferrd_facility_name#753734, decl_dedup_reference_id#735791 AS dedup_reference_id#753735, data_subcon_address_city#735772 AS subcontractor_city#753736, data_subcon_address_state#735773 AS subcontractor_state#753737, data_subcon_address_country#735774 AS subcontractor_country#753738, coalesce(data_subcon_address_lat#735775, fac_subcon_address_lat#735778) AS subcontractor_address_lat#753739, coalesce(data_subcon_address_lng#735776, fac_subcon_address_lng#735779) AS subcontractor_address_lng#753740, data_subcon_name#735777 AS subcontractor_name#753741, update_ts#735771 AS node_update_ts#753742, is_unknown_facility#743231, is_unknown_supplier#743482, is_unknown_subcontractor#743310, CASE WHEN (isnotnull(decl_facility_supplier_id#735785) AND coalesce(NOT decl_facility_sub_supplier#735786, false)) THEN Direct ELSE InDirect END AS DirectOrIndirectFacility#753743, resolved_fac_lat#740043 AS FacilityLat#753744, resolved_fac_lng#740162 AS FacilityLng#753745, 2026-10-17 07:30:07.102976 AS update_ts#753788]
Input [42]: [Child_Node#735793, NetworkID#735743, _id#735741, brand_context_id#735745, company_id#735746, data_subcon_address_city#735772, data_subcon_address_country#735774, data_subcon_address_lat#735775, data_subcon_address_lng#735776, data_subcon_address_state#735773, data_subcon_name#735777, decl_dedup_reference_id#735791, decl_facility_company_id#735788, decl_facility_create_date#735787, decl_facility_id#735784, decl_facility_sub_supplier#735786, decl_facility_supplier_id#735785, decl_preferrd_facility_id#735789, decl_preferrd_facility_name#735790, decl_subcon_create_date#735792, enabled#735762, fac_subcon_address_lat#735778, fac_subcon_address_lng#735779, is_latest#735744, is_unknown_facility#743231, is_unknown_subcontractor#743310, is_unknown_supplier#743482, launch_config_ref#735747, product_node_response_ref#735742, resolved_fac_address#739630, resolved_fac_city#736908, resolved_fac_country#738562, resolved_fac_lat#740043, resolved_fac_lng#740162, resolved_fac_state#736972, resolved_facility_name#736475, resolved_facility_ref#736035, resolved_sub_supplier_ref#742771, resolved_subcontractor#742430, resolved_supplier_ref#743389, revision_version#735748, update_ts#735771]
(13) DeserializeToObject
Input [41]: [NetworkID#735743, brand_context_id#735745, company_id#735746, launch_config_ref#735747, revision_version#735748, Child_Node#735793, is_latest#735744, is_latest_submitted#753716, facility_declaration_RefID#753717, Supplier_declaration_RefID#753718, reference_code#753719, facdec_Id#753720, FacilityName#753721, FacilityCity#753722, FacilityState#753723, FacilityCountry#753724, FacilityAddress#753725, fac_enabled#753726, facility_Subcontractor#753727, Sub_supplier_declaration_ref#753728, facility_id#753729, facility_first_created_date#753730, subcontractor_first_created_date#753731, facility_declared_company#753732, preferrd_facility_id#753733, preferrd_facility_name#753734, dedup_reference_id#753735, subcontractor_city#753736, subcontractor_state#753737, subcontractor_country#753738, subcontractor_address_lat#753739, subcontractor_address_lng#753740, subcontractor_name#753741, node_update_ts#753742, is_unknown_facility#743231, is_unknown_supplier#743482, is_unknown_subcontractor#743310, DirectOrIndirectFacility#753743, FacilityLat#753744, FacilityLng#753745, update_ts#753788]
Arguments: createexternalrow(NetworkID#735743.toString, brand_context_id#735745.toString, company_id#735746.toString, launch_config_ref#735747.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#735748, true, false, true), Child_Node#735793.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#735744, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#753716, true, false, true), facility_declaration_RefID#753717.toString, Supplier_declaration_RefID#753718.toString, reference_code#753719.toString, facdec_Id#753720.toString, FacilityName#753721.toString, FacilityCity#753722.toString, FacilityState#753723.toString, FacilityCountry#753724.toString, FacilityAddress#753725.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, fac_enabled#753726, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, facility_Subcontractor#753727, true, false, true), Sub_supplier_declaration_ref#753728.toString, facility_id#753729.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, facility_first_created_date#753730, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, subcontractor_first_created_date#753731, true, false, true), facility_declared_company#753732.toString, ... 58 more fields), obj#803904: org.apache.spark.sql.Row
(14) AdaptiveSparkPlan
Output [1]: [obj#803904]
Arguments: isFinalPlan=true