== Physical Plan ==
AdaptiveSparkPlan (14)
+- == Final Plan ==
ResultQueryStage (8), Statistics(sizeInBytes=8.0 EiB)
+- * Project (7)
+- ShuffleQueryStage (6), Statistics(sizeInBytes=16.0 B, rowCount=1)
+- Exchange (5)
+- * Project (4)
+- * Filter (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
+- == Initial Plan ==
CollectLimit (13)
+- Project (12)
+- Exchange (11)
+- Project (10)
+- Filter (9)
+- Scan parquet (1)
(1) Scan parquet
Output [2]: [marketUnit#15459060, handlingOfUnfulfilledDemands#15459078]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/market-unit]
PushedFilters: [EqualNullSafe(marketUnit,IW_MU_CRP-128628_2)]
ReadSchema: struct<marketUnit:string,handlingOfUnfulfilledDemands:struct<distributionCenter:struct<handlingOfUnfulfilledDemands:int>>>
(2) ColumnarToRow [codegen id : 1]
Input [2]: [marketUnit#15459060, handlingOfUnfulfilledDemands#15459078]
(3) Filter [codegen id : 1]
Input [2]: [marketUnit#15459060, handlingOfUnfulfilledDemands#15459078]
Condition : (marketUnit#15459060 <=> IW_MU_CRP-128628_2)
(4) Project [codegen id : 1]
Output [1]: [handlingOfUnfulfilledDemands#15459078.distributionCenter.handlingOfUnfulfilledDemands AS _extract_handlingOfUnfulfilledDemands#15463468]
Input [2]: [marketUnit#15459060, handlingOfUnfulfilledDemands#15459078]
(5) Exchange
Input [1]: [_extract_handlingOfUnfulfilledDemands#15463468]
Arguments: RoundRobinPartitioning(37), REPARTITION_BY_NUM, [plan_id=21684774]
(6) ShuffleQueryStage
Output [1]: [_extract_handlingOfUnfulfilledDemands#15463468]
Arguments: 0
(7) Project [codegen id : 2]
Output [1]: [coalesce(_extract_handlingOfUnfulfilledDemands#15463468, 1) AS coalesce(handlingOfUnfulfilledDemands.distributionCenter.handlingOfUnfulfilledDemands, 1)#15463467]
Input [1]: [_extract_handlingOfUnfulfilledDemands#15463468]
(8) ResultQueryStage
Output [1]: [coalesce(handlingOfUnfulfilledDemands.distributionCenter.handlingOfUnfulfilledDemands, 1)#15463467]
Arguments: 1
(9) Filter
Input [2]: [marketUnit#15459060, handlingOfUnfulfilledDemands#15459078]
Condition : (marketUnit#15459060 <=> IW_MU_CRP-128628_2)
(10) Project
Output [1]: [handlingOfUnfulfilledDemands#15459078.distributionCenter.handlingOfUnfulfilledDemands AS _extract_handlingOfUnfulfilledDemands#15463468]
Input [2]: [marketUnit#15459060, handlingOfUnfulfilledDemands#15459078]
(11) Exchange
Input [1]: [_extract_handlingOfUnfulfilledDemands#15463468]
Arguments: RoundRobinPartitioning(37), REPARTITION_BY_NUM, [plan_id=21684755]
(12) Project
Output [1]: [coalesce(_extract_handlingOfUnfulfilledDemands#15463468, 1) AS coalesce(handlingOfUnfulfilledDemands.distributionCenter.handlingOfUnfulfilledDemands, 1)#15463467]
Input [1]: [_extract_handlingOfUnfulfilledDemands#15463468]
(13) CollectLimit
Input [1]: [coalesce(handlingOfUnfulfilledDemands.distributionCenter.handlingOfUnfulfilledDemands, 1)#15463467]
Arguments: 1
(14) AdaptiveSparkPlan
Output [1]: [coalesce(handlingOfUnfulfilledDemands.distributionCenter.handlingOfUnfulfilledDemands, 1)#15463467]
Arguments: isFinalPlan=true