== Physical Plan ==
AdaptiveSparkPlan (11)
+- == Final Plan ==
ResultQueryStage (7), Statistics(sizeInBytes=8.0 EiB)
+- CollectLimit (6)
+- ShuffleQueryStage (5), Statistics(sizeInBytes=0.0 B, rowCount=4.34E+3)
+- Exchange (4)
+- * Project (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
+- == Initial Plan ==
CollectLimit (10)
+- Exchange (9)
+- Project (8)
+- Scan parquet (1)
(1) Scan parquet
Output [1]: [systemId#905181]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply]
ReadSchema: struct<>
(2) ColumnarToRow [codegen id : 1]
Input [1]: [systemId#905181]
(3) Project [codegen id : 1]
Output: []
Input [1]: [systemId#905181]
(4) Exchange
Input: []
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=351782]
(5) ShuffleQueryStage
Output: []
Arguments: 0
(6) CollectLimit
Input: []
Arguments: 1
(7) ResultQueryStage
Output: []
Arguments: 1
(8) Project
Output: []
Input [1]: [systemId#905181]
(9) Exchange
Input: []
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=351769]
(10) CollectLimit
Input: []
Arguments: 1
(11) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true