== Physical Plan ==
AdaptiveSparkPlan (16)
+- == Final Plan ==
* HashAggregate (9)
+- AQEShuffleRead (8)
+- ShuffleQueryStage (7), Statistics(sizeInBytes=32.0 B, rowCount=1)
+- Exchange (6)
+- * HashAggregate (5)
+- * Project (4)
+- * Filter (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
+- == Initial Plan ==
TakeOrderedAndProject (15)
+- HashAggregate (14)
+- Exchange (13)
+- HashAggregate (12)
+- Project (11)
+- Filter (10)
+- Scan parquet (1)
(1) Scan parquet
Output [1]: [OUT_MODE_3348#6663]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/uet/VISIT_3342]
PushedFilters: [IsNotNull(OUT_MODE_3348)]
ReadSchema: struct<OUT_MODE_3348:string>
(2) ColumnarToRow [codegen id : 1]
Input [1]: [OUT_MODE_3348#6663]
(3) Filter [codegen id : 1]
Input [1]: [OUT_MODE_3348#6663]
Condition : isnotnull(OUT_MODE_3348#6663)
(4) Project [codegen id : 1]
Output [1]: [OUT_MODE_3348#6663 AS COL_OUT_MODE_3348#6740]
Input [1]: [OUT_MODE_3348#6663]
(5) HashAggregate [codegen id : 1]
Input [1]: [COL_OUT_MODE_3348#6740]
Keys [1]: [COL_OUT_MODE_3348#6740]
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#6784L]
Results [2]: [COL_OUT_MODE_3348#6740, count#6785L]
(6) Exchange
Input [2]: [COL_OUT_MODE_3348#6740, count#6785L]
Arguments: hashpartitioning(COL_OUT_MODE_3348#6740, 10), ENSURE_REQUIREMENTS, [plan_id=1035]
(7) ShuffleQueryStage
Output [2]: [COL_OUT_MODE_3348#6740, count#6785L]
Arguments: 0
(8) AQEShuffleRead
Input [2]: [COL_OUT_MODE_3348#6740, count#6785L]
Arguments: coalesced
(9) HashAggregate [codegen id : 2]
Input [2]: [COL_OUT_MODE_3348#6740, count#6785L]
Keys [1]: [COL_OUT_MODE_3348#6740]
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#6775L]
Results [2]: [COL_OUT_MODE_3348#6740 AS COL_OUT_MODE_33481#6761, count(1)#6775L AS COL_OUT_MODE_33482#6777L]
(10) Filter
Input [1]: [OUT_MODE_3348#6663]
Condition : isnotnull(OUT_MODE_3348#6663)
(11) Project
Output [1]: [OUT_MODE_3348#6663 AS COL_OUT_MODE_3348#6740]
Input [1]: [OUT_MODE_3348#6663]
(12) HashAggregate
Input [1]: [COL_OUT_MODE_3348#6740]
Keys [1]: [COL_OUT_MODE_3348#6740]
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#6784L]
Results [2]: [COL_OUT_MODE_3348#6740, count#6785L]
(13) Exchange
Input [2]: [COL_OUT_MODE_3348#6740, count#6785L]
Arguments: hashpartitioning(COL_OUT_MODE_3348#6740, 10), ENSURE_REQUIREMENTS, [plan_id=1012]
(14) HashAggregate
Input [2]: [COL_OUT_MODE_3348#6740, count#6785L]
Keys [1]: [COL_OUT_MODE_3348#6740]
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#6775L]
Results [2]: [COL_OUT_MODE_3348#6740 AS COL_OUT_MODE_33481#6761, count(1)#6775L AS COL_OUT_MODE_33482#6777L]
(15) TakeOrderedAndProject
Input [2]: [COL_OUT_MODE_33481#6761, COL_OUT_MODE_33482#6777L]
Arguments: 10, [COL_OUT_MODE_33482#6777L DESC NULLS LAST], [COL_OUT_MODE_33481#6761, COL_OUT_MODE_33482#6777L]
(16) AdaptiveSparkPlan
Output [2]: [COL_OUT_MODE_33481#6761, COL_OUT_MODE_33482#6777L]
Arguments: isFinalPlan=true