== Physical Plan ==
AdaptiveSparkPlan (14)
+- == Final Plan ==
DeserializeToObject (10)
+- * Project (9)
+- * Filter (8)
+- TableCacheQueryStage (7), Statistics(sizeInBytes=22.5 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 ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
AND (n.networkId IN ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
) 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 ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
AND (n.networkId IN ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
) AS _t) [numPartitions=1] (3)
(1) InMemoryTableScan
Output [42]: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, is_unknown_supplier#10343891, launch_config_ref#10338539, product_node_response_ref#10338534, resolved_fac_address#10341397, resolved_fac_city#10340174, resolved_fac_country#10341335, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_fac_state#10341274, resolved_facility_name#10339335, resolved_facility_ref#10339276, resolved_sub_supplier_ref#10343590, resolved_subcontractor#10342824, resolved_supplier_ref#10343820, revision_version#10338540, update_ts#10338563]
Arguments: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, ... 18 more fields], [isnotnull(resolved_facility_ref#10339276)]
(2) InMemoryRelation
Arguments: [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, ... 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#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, 3), REPARTITION_BY_NUM, [plan_id=354295]
+- *(1) Project [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, ... 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 ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
AND (n.networkId IN ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
) AS _t) [numPartitions=1] [_id#10338533,product_node_response_ref#10338534,NetworkID#10338535,is_latest#10338536,brand_context_id#10338537,company_id#10338538,launch_config_ref#10338539,revision_version#10338540,facility_declaration_ref#10338541,data_facility_dec_ref#10338542,derived_facility_dec_ref#10338543,facility_name#10338544,data_facility_name#10338545,fac_city#10338546,data_city#10338547,fac_state#10338548,data_state#10338549,fac_country#10338550,data_country#10338551,fac_address_line1#10338552,data_address_line1#10338553,enabled#10338554,facility_default_ref#10338555,Subcontractor_supplier_default_ref#10338556,... 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#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, 3), REPARTITION_BY_NUM, [plan_id=353854]
+- Project [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, ... 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 ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
AND (n.networkId IN ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
) AS _t) [numPartitions=1] [_id#10338533,product_node_response_ref#10338534,NetworkID#10338535,is_latest#10338536,brand_context_id#10338537,company_id#10338538,launch_config_ref#10338539,revision_version#10338540,facility_declaration_ref#10338541,data_facility_dec_ref#10338542,derived_facility_dec_ref#10338543,facility_name#10338544,data_facility_name#10338545,fac_city#10338546,data_city#10338547,fac_state#10338548,data_state#10338549,fac_country#10338550,data_country#10338551,fac_address_line1#10338552,data_address_line1#10338553,enabled#10338554,facility_default_ref#10338555,Subcontractor_supplier_default_ref#10338556,... 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 ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
AND (n.networkId IN ('FFE035FED0951D5F11D23B2EA3F6B51F029C43B54A5DE89CA570015B14904F05', 'FFE7C943B1AF37F0AC1CAC5CA09B44D513403F693F75B0B3F3A52A2A51C40C3E', 'FFF5CEA41DF0AD7342B607295C40BB9CE36C55424FE87B58BE4D83796D950A69'))
) AS _t) [numPartitions=1]
Output [56]: [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, sub_contractor#10338557, facility_subcontartor#10338558, Sub_supplier_declaration_ref#10338559, supplier_declaration_ref#10338560, Value_process#10338561, data_key_values#10338562, update_ts#10338563, data_subcon_address_city#10338564, data_subcon_address_state#10338565, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_name#10338569, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, data_lat#10338572, fac_lat#10338573, data_ng#10338574, fac_lng#10338575, decl_facility_id#10338576, decl_facility_supplier_id#10338577, decl_facility_sub_supplier#10338578, decl_facility_create_date#10338579, decl_facility_company_id#10338580, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_dedup_reference_id#10338583, decl_subcon_create_date#10338584, Child_Node#10338585, node_derived_supplier_dec_ref#10338586, node_data_supplier_default_ref#10338587, node_supplier_dec_name#10338588]
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#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, sub_contractor#10338557, facility_subcontartor#10338558, Sub_supplier_declaration_ref#10338559, supplier_declaration_ref#10338560, Value_process#10338561, data_key_values#10338562, update_ts#10338563, data_subcon_address_city#10338564, data_subcon_address_state#10338565, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_name#10338569, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, data_lat#10338572, fac_lat#10338573, data_ng#10338574, fac_lng#10338575, decl_facility_id#10338576, decl_facility_supplier_id#10338577, decl_facility_sub_supplier#10338578, decl_facility_create_date#10338579, decl_facility_company_id#10338580, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_dedup_reference_id#10338583, decl_subcon_create_date#10338584, Child_Node#10338585, node_derived_supplier_dec_ref#10338586, node_data_supplier_default_ref#10338587, node_supplier_dec_name#10338588, coalesce(CASE WHEN (isnull(derived_facility_dec_ref#10338543) OR (derived_facility_dec_ref#10338543 = )) THEN null ELSE derived_facility_dec_ref#10338543 END, CASE WHEN (isnull(facility_default_ref#10338555) OR (facility_default_ref#10338555 = )) THEN null ELSE facility_default_ref#10338555 END) AS resolved_facility_ref#10339276, coalesce(CASE WHEN (isnull(data_facility_name#10338545) OR (data_facility_name#10338545 = )) THEN null ELSE data_facility_name#10338545 END, CASE WHEN (isnull(facility_name#10338544) OR (facility_name#10338544 = )) THEN null ELSE facility_name#10338544 END) AS resolved_facility_name#10339335, coalesce(CASE WHEN (isnull(data_city#10338547) OR (data_city#10338547 = )) THEN null ELSE data_city#10338547 END, CASE WHEN (isnull(fac_city#10338546) OR (fac_city#10338546 = )) THEN null ELSE fac_city#10338546 END) AS resolved_fac_city#10340174, coalesce(CASE WHEN (isnull(data_state#10338549) OR (data_state#10338549 = )) THEN null ELSE data_state#10338549 END, CASE WHEN (isnull(fac_state#10338548) OR (fac_state#10338548 = )) THEN null ELSE fac_state#10338548 END) AS resolved_fac_state#10341274, coalesce(CASE WHEN (isnull(data_country#10338551) OR (data_country#10338551 = )) THEN null ELSE data_country#10338551 END, CASE WHEN (isnull(fac_country#10338550) OR (fac_country#10338550 = )) THEN null ELSE fac_country#10338550 END) AS resolved_fac_country#10341335, coalesce(CASE WHEN (isnull(data_address_line1#10338553) OR (data_address_line1#10338553 = )) THEN null ELSE data_address_line1#10338553 END, CASE WHEN (isnull(fac_address_line1#10338552) OR (fac_address_line1#10338552 = )) THEN null ELSE fac_address_line1#10338552 END) AS resolved_fac_address#10341397, CASE WHEN isnotnull(data_lat#10338572) THEN cast(data_lat#10338572 as string) ELSE fac_lat#10338573 END AS resolved_fac_lat#10341720, CASE WHEN isnotnull(data_ng#10338574) THEN cast(data_ng#10338574 as string) ELSE fac_lng#10338575 END AS resolved_fac_lng#10341784, (coalesce(sub_contractor#10338557, false) OR coalesce((cast(facility_subcontartor#10338558 as int) = 1), false)) AS resolved_subcontractor#10342824, CASE WHEN (coalesce(sub_contractor#10338557, false) OR coalesce((cast(facility_subcontartor#10338558 as int) = 1), false)) THEN coalesce(CASE WHEN (isnull(Sub_supplier_declaration_ref#10338559) OR (Sub_supplier_declaration_ref#10338559 = )) THEN null ELSE Sub_supplier_declaration_ref#10338559 END, CASE WHEN (isnull(Subcontractor_supplier_default_ref#10338556) OR (Subcontractor_supplier_default_ref#10338556 = )) THEN null ELSE Subcontractor_supplier_default_ref#10338556 END) END AS resolved_sub_supplier_ref#10343590, ((isnull(data_facility_dec_ref#10338542) AND isnull(facility_declaration_ref#10338541)) AND coalesce((data_facility_name#10338545 = Facility Unknown), false)) AS is_unknown_facility#10343683, isnotnull(Subcontractor_supplier_default_ref#10338556) AS is_unknown_subcontractor#10343751, coalesce(CASE WHEN (isnull(node_derived_supplier_dec_ref#10338586) OR (node_derived_supplier_dec_ref#10338586 = )) THEN null ELSE node_derived_supplier_dec_ref#10338586 END, CASE WHEN (isnull(node_data_supplier_default_ref#10338587) OR (node_data_supplier_default_ref#10338587 = )) THEN null ELSE node_data_supplier_default_ref#10338587 END) AS resolved_supplier_ref#10343820, (isnull(node_derived_supplier_dec_ref#10338586) AND coalesce((node_supplier_dec_name#10338588 = Supplier Unknown), false)) AS is_unknown_supplier#10343891]
Input [56]: [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, sub_contractor#10338557, facility_subcontartor#10338558, Sub_supplier_declaration_ref#10338559, supplier_declaration_ref#10338560, Value_process#10338561, data_key_values#10338562, update_ts#10338563, data_subcon_address_city#10338564, data_subcon_address_state#10338565, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_name#10338569, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, data_lat#10338572, fac_lat#10338573, data_ng#10338574, fac_lng#10338575, decl_facility_id#10338576, decl_facility_supplier_id#10338577, decl_facility_sub_supplier#10338578, decl_facility_create_date#10338579, decl_facility_company_id#10338580, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_dedup_reference_id#10338583, decl_subcon_create_date#10338584, Child_Node#10338585, node_derived_supplier_dec_ref#10338586, node_data_supplier_default_ref#10338587, node_supplier_dec_name#10338588]
(5) Exchange
Input [70]: [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, sub_contractor#10338557, facility_subcontartor#10338558, Sub_supplier_declaration_ref#10338559, supplier_declaration_ref#10338560, Value_process#10338561, data_key_values#10338562, update_ts#10338563, data_subcon_address_city#10338564, data_subcon_address_state#10338565, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_name#10338569, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, data_lat#10338572, fac_lat#10338573, data_ng#10338574, fac_lng#10338575, decl_facility_id#10338576, decl_facility_supplier_id#10338577, decl_facility_sub_supplier#10338578, decl_facility_create_date#10338579, decl_facility_company_id#10338580, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_dedup_reference_id#10338583, decl_subcon_create_date#10338584, Child_Node#10338585, node_derived_supplier_dec_ref#10338586, node_data_supplier_default_ref#10338587, node_supplier_dec_name#10338588, resolved_facility_ref#10339276, resolved_facility_name#10339335, resolved_fac_city#10340174, resolved_fac_state#10341274, resolved_fac_country#10341335, resolved_fac_address#10341397, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_subcontractor#10342824, resolved_sub_supplier_ref#10343590, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, resolved_supplier_ref#10343820, is_unknown_supplier#10343891]
Arguments: hashpartitioning(brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, 3), REPARTITION_BY_NUM, [plan_id=353854]
(6) AdaptiveSparkPlan
Output [70]: [_id#10338533, product_node_response_ref#10338534, NetworkID#10338535, is_latest#10338536, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, facility_declaration_ref#10338541, data_facility_dec_ref#10338542, derived_facility_dec_ref#10338543, facility_name#10338544, data_facility_name#10338545, fac_city#10338546, data_city#10338547, fac_state#10338548, data_state#10338549, fac_country#10338550, data_country#10338551, fac_address_line1#10338552, data_address_line1#10338553, enabled#10338554, facility_default_ref#10338555, Subcontractor_supplier_default_ref#10338556, sub_contractor#10338557, facility_subcontartor#10338558, Sub_supplier_declaration_ref#10338559, supplier_declaration_ref#10338560, Value_process#10338561, data_key_values#10338562, update_ts#10338563, data_subcon_address_city#10338564, data_subcon_address_state#10338565, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_name#10338569, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, data_lat#10338572, fac_lat#10338573, data_ng#10338574, fac_lng#10338575, decl_facility_id#10338576, decl_facility_supplier_id#10338577, decl_facility_sub_supplier#10338578, decl_facility_create_date#10338579, decl_facility_company_id#10338580, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_dedup_reference_id#10338583, decl_subcon_create_date#10338584, Child_Node#10338585, node_derived_supplier_dec_ref#10338586, node_data_supplier_default_ref#10338587, node_supplier_dec_name#10338588, resolved_facility_ref#10339276, resolved_facility_name#10339335, resolved_fac_city#10340174, resolved_fac_state#10341274, resolved_fac_country#10341335, resolved_fac_address#10341397, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_subcontractor#10342824, resolved_sub_supplier_ref#10343590, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, resolved_supplier_ref#10343820, is_unknown_supplier#10343891]
Arguments: isFinalPlan=false
(7) TableCacheQueryStage
Output [42]: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, is_unknown_supplier#10343891, launch_config_ref#10338539, product_node_response_ref#10338534, resolved_fac_address#10341397, resolved_fac_city#10340174, resolved_fac_country#10341335, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_fac_state#10341274, resolved_facility_name#10339335, resolved_facility_ref#10339276, resolved_sub_supplier_ref#10343590, resolved_subcontractor#10342824, resolved_supplier_ref#10343820, revision_version#10338540, update_ts#10338563]
Arguments: 0
(8) Filter [codegen id : 1]
Input [42]: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, is_unknown_supplier#10343891, launch_config_ref#10338539, product_node_response_ref#10338534, resolved_fac_address#10341397, resolved_fac_city#10340174, resolved_fac_country#10341335, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_fac_state#10341274, resolved_facility_name#10339335, resolved_facility_ref#10339276, resolved_sub_supplier_ref#10343590, resolved_subcontractor#10342824, resolved_supplier_ref#10343820, revision_version#10338540, update_ts#10338563]
Condition : isnotnull(resolved_facility_ref#10339276)
(9) Project [codegen id : 1]
Output [41]: [NetworkID#10338535, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, Child_Node#10338585, is_latest#10338536, false AS is_latest_submitted#10351639, resolved_facility_ref#10339276 AS facility_declaration_RefID#10351640, resolved_supplier_ref#10343820 AS Supplier_declaration_RefID#10351641, product_node_response_ref#10338534 AS reference_code#10351642, _id#10338533 AS facdec_Id#10351643, resolved_facility_name#10339335 AS FacilityName#10351644, resolved_fac_city#10340174 AS FacilityCity#10351645, resolved_fac_state#10341274 AS FacilityState#10351646, resolved_fac_country#10341335 AS FacilityCountry#10351647, resolved_fac_address#10341397 AS FacilityAddress#10351648, enabled#10338554 AS fac_enabled#10351649, resolved_subcontractor#10342824 AS facility_Subcontractor#10351650, resolved_sub_supplier_ref#10343590 AS Sub_supplier_declaration_ref#10351651, decl_facility_id#10338576 AS facility_id#10351652, decl_facility_create_date#10338579 AS facility_first_created_date#10351653, CASE WHEN isnotnull(resolved_sub_supplier_ref#10343590) THEN decl_subcon_create_date#10338584 END AS subcontractor_first_created_date#10351654, decl_facility_company_id#10338580 AS facility_declared_company#10351655, decl_preferrd_facility_id#10338581 AS preferrd_facility_id#10351656, decl_preferrd_facility_name#10338582 AS preferrd_facility_name#10351657, decl_dedup_reference_id#10338583 AS dedup_reference_id#10351658, data_subcon_address_city#10338564 AS subcontractor_city#10351659, data_subcon_address_state#10338565 AS subcontractor_state#10351660, data_subcon_address_country#10338566 AS subcontractor_country#10351661, coalesce(data_subcon_address_lat#10338567, fac_subcon_address_lat#10338570) AS subcontractor_address_lat#10351662, coalesce(data_subcon_address_lng#10338568, fac_subcon_address_lng#10338571) AS subcontractor_address_lng#10351663, data_subcon_name#10338569 AS subcontractor_name#10351664, update_ts#10338563 AS node_update_ts#10351665, is_unknown_facility#10343683, is_unknown_supplier#10343891, is_unknown_subcontractor#10343751, CASE WHEN (isnotnull(decl_facility_supplier_id#10338577) AND coalesce(NOT decl_facility_sub_supplier#10338578, false)) THEN Direct ELSE InDirect END AS DirectOrIndirectFacility#10351666, resolved_fac_lat#10341720 AS FacilityLat#10351667, resolved_fac_lng#10341784 AS FacilityLng#10351668, 2026-10-16 07:30:22.066784 AS update_ts#10351669]
Input [42]: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, is_unknown_supplier#10343891, launch_config_ref#10338539, product_node_response_ref#10338534, resolved_fac_address#10341397, resolved_fac_city#10340174, resolved_fac_country#10341335, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_fac_state#10341274, resolved_facility_name#10339335, resolved_facility_ref#10339276, resolved_sub_supplier_ref#10343590, resolved_subcontractor#10342824, resolved_supplier_ref#10343820, revision_version#10338540, update_ts#10338563]
(10) DeserializeToObject
Input [41]: [NetworkID#10338535, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, Child_Node#10338585, is_latest#10338536, is_latest_submitted#10351639, facility_declaration_RefID#10351640, Supplier_declaration_RefID#10351641, reference_code#10351642, facdec_Id#10351643, FacilityName#10351644, FacilityCity#10351645, FacilityState#10351646, FacilityCountry#10351647, FacilityAddress#10351648, fac_enabled#10351649, facility_Subcontractor#10351650, Sub_supplier_declaration_ref#10351651, facility_id#10351652, facility_first_created_date#10351653, subcontractor_first_created_date#10351654, facility_declared_company#10351655, preferrd_facility_id#10351656, preferrd_facility_name#10351657, dedup_reference_id#10351658, subcontractor_city#10351659, subcontractor_state#10351660, subcontractor_country#10351661, subcontractor_address_lat#10351662, subcontractor_address_lng#10351663, subcontractor_name#10351664, node_update_ts#10351665, is_unknown_facility#10343683, is_unknown_supplier#10343891, is_unknown_subcontractor#10343751, DirectOrIndirectFacility#10351666, FacilityLat#10351667, FacilityLng#10351668, update_ts#10351669]
Arguments: createexternalrow(NetworkID#10338535.toString, brand_context_id#10338537.toString, company_id#10338538.toString, launch_config_ref#10338539.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#10338540, true, false, true), Child_Node#10338585.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#10338536, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#10351639, true, false, true), facility_declaration_RefID#10351640.toString, Supplier_declaration_RefID#10351641.toString, reference_code#10351642.toString, facdec_Id#10351643.toString, FacilityName#10351644.toString, FacilityCity#10351645.toString, FacilityState#10351646.toString, FacilityCountry#10351647.toString, FacilityAddress#10351648.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, fac_enabled#10351649, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, facility_Subcontractor#10351650, true, false, true), Sub_supplier_declaration_ref#10351651.toString, facility_id#10351652.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, facility_first_created_date#10351653, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, subcontractor_first_created_date#10351654, true, false, true), facility_declared_company#10351655.toString, ... 58 more fields), obj#10363678: org.apache.spark.sql.Row
(11) Filter
Input [42]: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, is_unknown_supplier#10343891, launch_config_ref#10338539, product_node_response_ref#10338534, resolved_fac_address#10341397, resolved_fac_city#10340174, resolved_fac_country#10341335, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_fac_state#10341274, resolved_facility_name#10339335, resolved_facility_ref#10339276, resolved_sub_supplier_ref#10343590, resolved_subcontractor#10342824, resolved_supplier_ref#10343820, revision_version#10338540, update_ts#10338563]
Condition : isnotnull(resolved_facility_ref#10339276)
(12) Project
Output [41]: [NetworkID#10338535, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, Child_Node#10338585, is_latest#10338536, false AS is_latest_submitted#10351639, resolved_facility_ref#10339276 AS facility_declaration_RefID#10351640, resolved_supplier_ref#10343820 AS Supplier_declaration_RefID#10351641, product_node_response_ref#10338534 AS reference_code#10351642, _id#10338533 AS facdec_Id#10351643, resolved_facility_name#10339335 AS FacilityName#10351644, resolved_fac_city#10340174 AS FacilityCity#10351645, resolved_fac_state#10341274 AS FacilityState#10351646, resolved_fac_country#10341335 AS FacilityCountry#10351647, resolved_fac_address#10341397 AS FacilityAddress#10351648, enabled#10338554 AS fac_enabled#10351649, resolved_subcontractor#10342824 AS facility_Subcontractor#10351650, resolved_sub_supplier_ref#10343590 AS Sub_supplier_declaration_ref#10351651, decl_facility_id#10338576 AS facility_id#10351652, decl_facility_create_date#10338579 AS facility_first_created_date#10351653, CASE WHEN isnotnull(resolved_sub_supplier_ref#10343590) THEN decl_subcon_create_date#10338584 END AS subcontractor_first_created_date#10351654, decl_facility_company_id#10338580 AS facility_declared_company#10351655, decl_preferrd_facility_id#10338581 AS preferrd_facility_id#10351656, decl_preferrd_facility_name#10338582 AS preferrd_facility_name#10351657, decl_dedup_reference_id#10338583 AS dedup_reference_id#10351658, data_subcon_address_city#10338564 AS subcontractor_city#10351659, data_subcon_address_state#10338565 AS subcontractor_state#10351660, data_subcon_address_country#10338566 AS subcontractor_country#10351661, coalesce(data_subcon_address_lat#10338567, fac_subcon_address_lat#10338570) AS subcontractor_address_lat#10351662, coalesce(data_subcon_address_lng#10338568, fac_subcon_address_lng#10338571) AS subcontractor_address_lng#10351663, data_subcon_name#10338569 AS subcontractor_name#10351664, update_ts#10338563 AS node_update_ts#10351665, is_unknown_facility#10343683, is_unknown_supplier#10343891, is_unknown_subcontractor#10343751, CASE WHEN (isnotnull(decl_facility_supplier_id#10338577) AND coalesce(NOT decl_facility_sub_supplier#10338578, false)) THEN Direct ELSE InDirect END AS DirectOrIndirectFacility#10351666, resolved_fac_lat#10341720 AS FacilityLat#10351667, resolved_fac_lng#10341784 AS FacilityLng#10351668, 2026-10-16 07:30:22.066784 AS update_ts#10351669]
Input [42]: [Child_Node#10338585, NetworkID#10338535, _id#10338533, brand_context_id#10338537, company_id#10338538, data_subcon_address_city#10338564, data_subcon_address_country#10338566, data_subcon_address_lat#10338567, data_subcon_address_lng#10338568, data_subcon_address_state#10338565, data_subcon_name#10338569, decl_dedup_reference_id#10338583, decl_facility_company_id#10338580, decl_facility_create_date#10338579, decl_facility_id#10338576, decl_facility_sub_supplier#10338578, decl_facility_supplier_id#10338577, decl_preferrd_facility_id#10338581, decl_preferrd_facility_name#10338582, decl_subcon_create_date#10338584, enabled#10338554, fac_subcon_address_lat#10338570, fac_subcon_address_lng#10338571, is_latest#10338536, is_unknown_facility#10343683, is_unknown_subcontractor#10343751, is_unknown_supplier#10343891, launch_config_ref#10338539, product_node_response_ref#10338534, resolved_fac_address#10341397, resolved_fac_city#10340174, resolved_fac_country#10341335, resolved_fac_lat#10341720, resolved_fac_lng#10341784, resolved_fac_state#10341274, resolved_facility_name#10339335, resolved_facility_ref#10339276, resolved_sub_supplier_ref#10343590, resolved_subcontractor#10342824, resolved_supplier_ref#10343820, revision_version#10338540, update_ts#10338563]
(13) DeserializeToObject
Input [41]: [NetworkID#10338535, brand_context_id#10338537, company_id#10338538, launch_config_ref#10338539, revision_version#10338540, Child_Node#10338585, is_latest#10338536, is_latest_submitted#10351639, facility_declaration_RefID#10351640, Supplier_declaration_RefID#10351641, reference_code#10351642, facdec_Id#10351643, FacilityName#10351644, FacilityCity#10351645, FacilityState#10351646, FacilityCountry#10351647, FacilityAddress#10351648, fac_enabled#10351649, facility_Subcontractor#10351650, Sub_supplier_declaration_ref#10351651, facility_id#10351652, facility_first_created_date#10351653, subcontractor_first_created_date#10351654, facility_declared_company#10351655, preferrd_facility_id#10351656, preferrd_facility_name#10351657, dedup_reference_id#10351658, subcontractor_city#10351659, subcontractor_state#10351660, subcontractor_country#10351661, subcontractor_address_lat#10351662, subcontractor_address_lng#10351663, subcontractor_name#10351664, node_update_ts#10351665, is_unknown_facility#10343683, is_unknown_supplier#10343891, is_unknown_subcontractor#10343751, DirectOrIndirectFacility#10351666, FacilityLat#10351667, FacilityLng#10351668, update_ts#10351669]
Arguments: createexternalrow(NetworkID#10338535.toString, brand_context_id#10338537.toString, company_id#10338538.toString, launch_config_ref#10338539.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#10338540, true, false, true), Child_Node#10338585.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#10338536, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#10351639, true, false, true), facility_declaration_RefID#10351640.toString, Supplier_declaration_RefID#10351641.toString, reference_code#10351642.toString, facdec_Id#10351643.toString, FacilityName#10351644.toString, FacilityCity#10351645.toString, FacilityState#10351646.toString, FacilityCountry#10351647.toString, FacilityAddress#10351648.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, fac_enabled#10351649, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, facility_Subcontractor#10351650, true, false, true), Sub_supplier_declaration_ref#10351651.toString, facility_id#10351652.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, facility_first_created_date#10351653, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Date), toJavaDate, subcontractor_first_created_date#10351654, true, false, true), facility_declared_company#10351655.toString, ... 58 more fields), obj#10363678: org.apache.spark.sql.Row
(14) AdaptiveSparkPlan
Output [1]: [obj#10363678]
Arguments: isFinalPlan=true