digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
1 [labelType="html" label="<br><b>DeserializeToObject</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n325 ms (1 ms, 38 ms, 149 ms (stage 13382.0: task 30300))";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
}
4 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 25<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 13378.0: task 30294))<br>remote merged bytes read total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 13382.0: task 30300))<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 13382.0: task 30300))<br>remote merged blocks fetched: 0<br>records read: 25<br>local bytes read total (min, med, max (stageId: taskId))<br>2.3 KiB (0.0 B, 446.0 B, 1044.0 B (stage 13382.0: task 30306))<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 13382.0: task 30300))<br>remote bytes read total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 13382.0: task 30300))<br>merged fetch fallback count: 0<br>local blocks read: 4<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>7.0 KiB (0.0 B, 0.0 B, 7.0 KiB (stage 13378.0: task 30294))<br>local merged bytes read total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 13382.0: task 30300))<br>number of partitions: 5<br>remote reqs duration total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 13382.0: task 30300))<br>remote bytes read to disk total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 13382.0: task 30300))<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>2.3 KiB (0.0 B, 0.0 B, 2.3 KiB (stage 13378.0: task 30294))"];
subgraph cluster5 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n1 ms (0 ms, 0 ms, 1 ms (stage 13378.0: task 30294))";
6 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 25"];
7 [labelType="html" label="<b>Scan JDBCRelation((<br> SELECT DISTINCT<br> pfd.networkId AS NetworkID, pfd.is_latest,<br> pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,<br> CAST(COALESCE(m.facility_declaration_ref, pfd.derived_facility_dec_ref,<br> pfd.facility_default_ref) AS varchar(100)) <br> AS facility_declaration_ref,<br> pfd.Value_process, SUBSTRING(m.Materials, 0, 800) AS Materials,<br> n._id AS Child_Node<br> FROM dbo.dimscm_product_field_details_response pfd<br> INNER JOIN dbo.dimscm_product_node_response n<br> ON n.networkId = pfd.networkId<br> AND n.reference_code = pfd.product_node_response_ref<br> LEFT JOIN dbo.dim_compute_scm_product_field_details_response_materials m<br> ON m.networkId = pfd.networkId<br> AND (m.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))<br> AND m.product_node_response_ref = CAST(pfd.product_node_response_ref AS varchar(200))<br> AND m.facility_declaration_ref = CAST(COALESCE(pfd.derived_facility_dec_ref, pfd.facility_default_ref) AS varchar(200))<br> AND m.Value_process = pfd.Value_process<br> WHERE (pfd.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))<br> AND (n.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))<br> ) AS _t) [numPartitions=1] </b><br><br>number of output rows: 67"];
}
1->0;
3->1;
4->3;
6->4;
7->6;
}
8
AdaptiveSparkPlan isFinalPlan=true
DeserializeToObject createexternalrow(NetworkID#9965826.toString, brand_context_id#9965828.toString, company_id#9965829.toString, launch_config_ref#9965830.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#9965831, true, false, true), Child_Node#9965835.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#9965827, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#9965858, true, false, true), facility_declaration_RefID#9965859.toString, Value_process#9965860.toString, Material#9965861.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Timestamp), toJavaTimestamp, update_ts#9965862, true, false, true), StructField(NetworkID,StringType,true), StructField(brand_context_id,StringType,true), StructField(company_id,StringType,true), StructField(launch_config_ref,StringType,true), StructField(revision_version,ShortType,true), StructField(Child_Node,StringType,true), StructField(is_latest,BooleanType,true), StructField(is_latest_submitted,BooleanType,false), StructField(facility_declaration_RefID,StringType,true), StructField(Value_process,StringType,true), StructField(Material,StringType,true), StructField(update_ts,TimestampType,false)), obj#10014293: org.apache.spark.sql.Row
Project [NetworkID#9965826, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, Child_Node#9965835, is_latest#9965827, false AS is_latest_submitted#9965858, trim(facility_declaration_ref#9965832, None) AS facility_declaration_RefID#9965859, trim(Value_process#9965833, None) AS Value_process#9965860, CASE WHEN (isnull(trim(Materials#9965834, None)) OR (trim(Materials#9965834, None) = )) THEN null ELSE trim(Materials#9965834, None) END AS Material#9965861, 2026-10-16 07:30:22.066784 AS update_ts#9965862]
WholeStageCodegen (2)
Exchange hashpartitioning(brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, 5), REPARTITION_BY_NUM, [plan_id=342775]
Filter isnotnull(facility_declaration_ref#9965832)
Scan JDBCRelation((
SELECT DISTINCT
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
CAST(COALESCE(m.facility_declaration_ref, pfd.derived_facility_dec_ref,
pfd.facility_default_ref) AS varchar(100))
AS facility_declaration_ref,
pfd.Value_process, SUBSTRING(m.Materials, 0, 800) AS Materials,
n._id AS Child_Node
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.dim_compute_scm_product_field_details_response_materials m
ON m.networkId = pfd.networkId
AND (m.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND m.product_node_response_ref = CAST(pfd.product_node_response_ref AS varchar(200))
AND m.facility_declaration_ref = CAST(COALESCE(pfd.derived_facility_dec_ref, pfd.facility_default_ref) AS varchar(200))
AND m.Value_process = pfd.Value_process
WHERE (pfd.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND (n.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
) AS _t) [numPartitions=1] [NetworkID#9965826,is_latest#9965827,brand_context_id#9965828,company_id#9965829,launch_config_ref#9965830,revision_version#9965831,facility_declaration_ref#9965832,Value_process#9965833,Materials#9965834,Child_Node#9965835] PushedFilters: [IsNotNull(facility_declaration_ref)], ReadSchema: struct<NetworkID:string,is_latest:boolean,brand_context_id:string,company_id:string,launch_config...
WholeStageCodegen (1)
== Physical Plan ==
AdaptiveSparkPlan (10)
+- == Final Plan ==
DeserializeToObject (6)
+- * Project (5)
+- ShuffleQueryStage (4), Statistics(sizeInBytes=7.0 KiB, rowCount=25)
+- Exchange (3)
+- * Filter (2)
+- * Scan JDBCRelation((
SELECT DISTINCT
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
CAST(COALESCE(m.facility_declaration_ref, pfd.derived_facility_dec_ref,
pfd.facility_default_ref) AS varchar(100))
AS facility_declaration_ref,
pfd.Value_process, SUBSTRING(m.Materials, 0, 800) AS Materials,
n._id AS Child_Node
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.dim_compute_scm_product_field_details_response_materials m
ON m.networkId = pfd.networkId
AND (m.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND m.product_node_response_ref = CAST(pfd.product_node_response_ref AS varchar(200))
AND m.facility_declaration_ref = CAST(COALESCE(pfd.derived_facility_dec_ref, pfd.facility_default_ref) AS varchar(200))
AND m.Value_process = pfd.Value_process
WHERE (pfd.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND (n.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
) AS _t) [numPartitions=1] (1)
+- == Initial Plan ==
DeserializeToObject (9)
+- Project (8)
+- Exchange (7)
+- Filter (2)
+- Scan JDBCRelation((
SELECT DISTINCT
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
CAST(COALESCE(m.facility_declaration_ref, pfd.derived_facility_dec_ref,
pfd.facility_default_ref) AS varchar(100))
AS facility_declaration_ref,
pfd.Value_process, SUBSTRING(m.Materials, 0, 800) AS Materials,
n._id AS Child_Node
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.dim_compute_scm_product_field_details_response_materials m
ON m.networkId = pfd.networkId
AND (m.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND m.product_node_response_ref = CAST(pfd.product_node_response_ref AS varchar(200))
AND m.facility_declaration_ref = CAST(COALESCE(pfd.derived_facility_dec_ref, pfd.facility_default_ref) AS varchar(200))
AND m.Value_process = pfd.Value_process
WHERE (pfd.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND (n.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
) AS _t) [numPartitions=1] (1)
(1) Scan JDBCRelation((
SELECT DISTINCT
pfd.networkId AS NetworkID, pfd.is_latest,
pfd.brand_context_id, pfd.company_id, pfd.launch_config_ref, pfd.revision_version,
CAST(COALESCE(m.facility_declaration_ref, pfd.derived_facility_dec_ref,
pfd.facility_default_ref) AS varchar(100))
AS facility_declaration_ref,
pfd.Value_process, SUBSTRING(m.Materials, 0, 800) AS Materials,
n._id AS Child_Node
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.dim_compute_scm_product_field_details_response_materials m
ON m.networkId = pfd.networkId
AND (m.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND m.product_node_response_ref = CAST(pfd.product_node_response_ref AS varchar(200))
AND m.facility_declaration_ref = CAST(COALESCE(pfd.derived_facility_dec_ref, pfd.facility_default_ref) AS varchar(200))
AND m.Value_process = pfd.Value_process
WHERE (pfd.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
AND (n.networkId IN ('F5D19C3427DA9B77D2F973426247AF5D5AA7A71860FDC8AB07CA4A0142D0E44D', 'F5D8111A076D0F31FFB777ABB48CFA631E7EC83F8C481A9CC2910F82971E4F4D', 'F5DC748058952BD1C1CB71189CBCB19CE1F5B8DDE3379E970F8B24C00856D9E6', 'F5EECBEB8B9624CE6C70A5F377E9271216BE44E2C25E06FC7CBCC296C19221E5', 'F5F1C31FBA06D4F664868F5165D042693077BA7C0BFC99AEBB1E2C649F34572E'))
) AS _t) [numPartitions=1] [codegen id : 1]
Output [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
PushedFilters: [IsNotNull(facility_declaration_ref)]
ReadSchema: struct<NetworkID:string,is_latest:boolean,brand_context_id:string,company_id:string,launch_config_ref:string,revision_version:smallint,facility_declaration_ref:string,Value_process:string,Materials:string,Child_Node:string>
(2) Filter [codegen id : 1]
Input [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
Condition : isnotnull(facility_declaration_ref#9965832)
(3) Exchange
Input [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
Arguments: hashpartitioning(brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, 5), REPARTITION_BY_NUM, [plan_id=342775]
(4) ShuffleQueryStage
Output [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
Arguments: 0
(5) Project [codegen id : 2]
Output [12]: [NetworkID#9965826, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, Child_Node#9965835, is_latest#9965827, false AS is_latest_submitted#9965858, trim(facility_declaration_ref#9965832, None) AS facility_declaration_RefID#9965859, trim(Value_process#9965833, None) AS Value_process#9965860, CASE WHEN (isnull(trim(Materials#9965834, None)) OR (trim(Materials#9965834, None) = )) THEN null ELSE trim(Materials#9965834, None) END AS Material#9965861, 2026-10-16 07:30:22.066784 AS update_ts#9965862]
Input [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
(6) DeserializeToObject
Input [12]: [NetworkID#9965826, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, Child_Node#9965835, is_latest#9965827, is_latest_submitted#9965858, facility_declaration_RefID#9965859, Value_process#9965860, Material#9965861, update_ts#9965862]
Arguments: createexternalrow(NetworkID#9965826.toString, brand_context_id#9965828.toString, company_id#9965829.toString, launch_config_ref#9965830.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#9965831, true, false, true), Child_Node#9965835.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#9965827, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#9965858, true, false, true), facility_declaration_RefID#9965859.toString, Value_process#9965860.toString, Material#9965861.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Timestamp), toJavaTimestamp, update_ts#9965862, true, false, true), StructField(NetworkID,StringType,true), StructField(brand_context_id,StringType,true), StructField(company_id,StringType,true), StructField(launch_config_ref,StringType,true), StructField(revision_version,ShortType,true), StructField(Child_Node,StringType,true), StructField(is_latest,BooleanType,true), StructField(is_latest_submitted,BooleanType,false), StructField(facility_declaration_RefID,StringType,true), StructField(Value_process,StringType,true), StructField(Material,StringType,true), StructField(update_ts,TimestampType,false)), obj#10014293: org.apache.spark.sql.Row
(7) Exchange
Input [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
Arguments: hashpartitioning(brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, 5), REPARTITION_BY_NUM, [plan_id=342765]
(8) Project
Output [12]: [NetworkID#9965826, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, Child_Node#9965835, is_latest#9965827, false AS is_latest_submitted#9965858, trim(facility_declaration_ref#9965832, None) AS facility_declaration_RefID#9965859, trim(Value_process#9965833, None) AS Value_process#9965860, CASE WHEN (isnull(trim(Materials#9965834, None)) OR (trim(Materials#9965834, None) = )) THEN null ELSE trim(Materials#9965834, None) END AS Material#9965861, 2026-10-16 07:30:22.066784 AS update_ts#9965862]
Input [10]: [NetworkID#9965826, is_latest#9965827, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, facility_declaration_ref#9965832, Value_process#9965833, Materials#9965834, Child_Node#9965835]
(9) DeserializeToObject
Input [12]: [NetworkID#9965826, brand_context_id#9965828, company_id#9965829, launch_config_ref#9965830, revision_version#9965831, Child_Node#9965835, is_latest#9965827, is_latest_submitted#9965858, facility_declaration_RefID#9965859, Value_process#9965860, Material#9965861, update_ts#9965862]
Arguments: createexternalrow(NetworkID#9965826.toString, brand_context_id#9965828.toString, company_id#9965829.toString, launch_config_ref#9965830.toString, staticinvoke(class java.lang.Short, ObjectType(class java.lang.Short), valueOf, revision_version#9965831, true, false, true), Child_Node#9965835.toString, staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest#9965827, true, false, true), staticinvoke(class java.lang.Boolean, ObjectType(class java.lang.Boolean), valueOf, is_latest_submitted#9965858, true, false, true), facility_declaration_RefID#9965859.toString, Value_process#9965860.toString, Material#9965861.toString, staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Timestamp), toJavaTimestamp, update_ts#9965862, true, false, true), StructField(NetworkID,StringType,true), StructField(brand_context_id,StringType,true), StructField(company_id,StringType,true), StructField(launch_config_ref,StringType,true), StructField(revision_version,ShortType,true), StructField(Child_Node,StringType,true), StructField(is_latest,BooleanType,true), StructField(is_latest_submitted,BooleanType,false), StructField(facility_declaration_RefID,StringType,true), StructField(Value_process,StringType,true), StructField(Material,StringType,true), StructField(update_ts,TimestampType,false)), obj#10014293: org.apache.spark.sql.Row
(10) AdaptiveSparkPlan
Output [1]: [obj#10014293]
Arguments: isFinalPlan=true