== Physical Plan ==
AdaptiveSparkPlan (12)
+- == Final Plan ==
ResultQueryStage (7), Statistics(sizeInBytes=8.0 EiB)
+- ShuffleQueryStage (6), Statistics(sizeInBytes=16.0 B, rowCount=1)
+- Exchange (5)
+- * Project (4)
+- * Filter (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
+- == Initial Plan ==
CollectLimit (11)
+- Exchange (10)
+- Project (9)
+- Filter (8)
+- Scan parquet (1)
(1) Scan parquet
Output [2]: [marketUnit#21518061, listingCheck#21518070]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/market-unit]
PushedFilters: [EqualNullSafe(marketUnit,SS_Test_1)]
ReadSchema: struct<marketUnit:string,listingCheck:int>
(2) ColumnarToRow [codegen id : 1]
Input [2]: [marketUnit#21518061, listingCheck#21518070]
(3) Filter [codegen id : 1]
Input [2]: [marketUnit#21518061, listingCheck#21518070]
Condition : (marketUnit#21518061 <=> SS_Test_1)
(4) Project [codegen id : 1]
Output [1]: [listingCheck#21518070]
Input [2]: [marketUnit#21518061, listingCheck#21518070]
(5) Exchange
Input [1]: [listingCheck#21518070]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=21258881]
(6) ShuffleQueryStage
Output [1]: [listingCheck#21518070]
Arguments: 0
(7) ResultQueryStage
Output [1]: [listingCheck#21518070]
Arguments: 1
(8) Filter
Input [2]: [marketUnit#21518061, listingCheck#21518070]
Condition : (marketUnit#21518061 <=> SS_Test_1)
(9) Project
Output [1]: [listingCheck#21518070]
Input [2]: [marketUnit#21518061, listingCheck#21518070]
(10) Exchange
Input [1]: [listingCheck#21518070]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=21258863]
(11) CollectLimit
Input [1]: [listingCheck#21518070]
Arguments: 1
(12) AdaptiveSparkPlan
Output [1]: [listingCheck#21518070]
Arguments: isFinalPlan=true