VeloxColumnarToRow
  TakeOrderedAndProjectExecTransformer [cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count,cnt1,cnt2,cnt3,cnt4,cnt5,cnt6]
    WholeStageCodegenTransformer (17)
      ProjectExecTransformer [cd_gender,cd_marital_status,cd_education_status,count(1),cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count]
        RegularHashAggregateExecTransformer [cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count,count] [count(1),count]
          InputIteratorTransformer
            InputAdapter
              ColumnarExchange [cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count,count] #1
                VeloxResizeBatches
                  WholeStageCodegenTransformer (16)
                    ProjectExecTransformer [cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count,count]
                      FlushableHashAggregateExecTransformer [cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count] [count,count]
                        ProjectExecTransformer [cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count]
                          ShuffledHashJoinExecTransformer [c_current_cdemo_sk,cd_demo_sk]
                            InputIteratorTransformer
                              InputAdapter
                                ColumnarExchange [c_current_cdemo_sk] #2
                                  VeloxResizeBatches
                                    WholeStageCodegenTransformer (14)
                                      ProjectExecTransformer [c_current_cdemo_sk]
                                        BroadcastHashJoinExecTransformer [c_current_addr_sk,ca_address_sk]
                                          ProjectExecTransformer [c_current_cdemo_sk,c_current_addr_sk]
                                            FilterExecTransformer [exists,exists]
                                              ShuffledHashJoinExecTransformer [c_customer_sk,cs_ship_customer_sk]
                                                ShuffledHashJoinExecTransformer [c_customer_sk,ws_bill_customer_sk]
                                                  ShuffledHashJoinExecTransformer [c_customer_sk,ss_customer_sk]
                                                    InputIteratorTransformer
                                                      InputAdapter
                                                        ColumnarExchange [c_customer_sk,c_current_cdemo_sk,c_current_addr_sk] #3
                                                          VeloxResizeBatches
                                                            WholeStageCodegenTransformer (3)
                                                              ProjectExecTransformer [c_customer_sk,c_current_cdemo_sk,c_current_addr_sk]
                                                                FilterExecTransformer [c_current_addr_sk,c_current_cdemo_sk]
                                                                  Subquery #1
                                                                    VeloxColumnarToRow
                                                                      WholeStageCodegenTransformer (2)
                                                                        RegularHashAggregateExecTransformer [bloom_filter_agg(xxhash64(ca_address_sk, 42), 2555, 57765, 0, 0),bloomFilter,buf,buf]
                                                                          InputIteratorTransformer
                                                                            InputAdapter
                                                                              ColumnarExchange #4
                                                                                VeloxResizeBatches
                                                                                  WholeStageCodegenTransformer (1)
                                                                                    FlushableHashAggregateExecTransformer [_pre_x] [buf,buf,buf]
                                                                                      ProjectExecTransformer [ca_address_sk]
                                                                                        FilterExecTransformer [ca_county,ca_address_sk]
                                                                                          FileSourceScanExecTransformer parquet spark_catalog.default.customer_address [ca_address_sk,ca_county]
                                                                  FileSourceScanExecTransformer parquet spark_catalog.default.customer [c_customer_sk,c_current_cdemo_sk,c_current_addr_sk]
                                                                    Subquery #1
                                                                      VeloxColumnarToRow
                                                                        WholeStageCodegenTransformer (2)
                                                                          RegularHashAggregateExecTransformer [bloom_filter_agg(xxhash64(ca_address_sk, 42), 2555, 57765, 0, 0),bloomFilter,buf,buf]
                                                                            InputIteratorTransformer
                                                                              InputAdapter
                                                                                ColumnarExchange #4
                                                                                  VeloxResizeBatches
                                                                                    WholeStageCodegenTransformer (1)
                                                                                      FlushableHashAggregateExecTransformer [_pre_x] [buf,buf,buf]
                                                                                        ProjectExecTransformer [ca_address_sk]
                                                                                          FilterExecTransformer [ca_county,ca_address_sk]
                                                                                            FileSourceScanExecTransformer parquet spark_catalog.default.customer_address [ca_address_sk,ca_county]
                                                    InputIteratorTransformer
                                                      InputAdapter
                                                        ColumnarExchange [ss_customer_sk] #5
                                                          VeloxResizeBatches
                                                            WholeStageCodegenTransformer (6)
                                                              ProjectExecTransformer [ss_customer_sk]
                                                                BroadcastHashJoinExecTransformer [ss_sold_date_sk,d_date_sk]
                                                                  FileSourceScanExecTransformer parquet spark_catalog.default.store_sales [ss_customer_sk,ss_sold_date_sk]
                                                                    ColumnarSubqueryBroadcast [d_date_sk] #2
                                                                      ColumnarBroadcastExchange #6
                                                                        WholeStageCodegenTransformer (4)
                                                                          ProjectExecTransformer [d_date_sk]
                                                                            FilterExecTransformer [d_year,d_moy,d_date_sk]
                                                                              FileSourceScanExecTransformer parquet spark_catalog.default.date_dim [d_date_sk,d_year,d_moy]
                                                                  InputIteratorTransformer
                                                                    InputAdapter
                                                                      ReusedExchange [d_date_sk] #6
                                                  InputIteratorTransformer
                                                    InputAdapter
                                                      ColumnarExchange [ws_bill_customer_sk] #7
                                                        VeloxResizeBatches
                                                          WholeStageCodegenTransformer (9)
                                                            ProjectExecTransformer [ws_bill_customer_sk]
                                                              BroadcastHashJoinExecTransformer [ws_sold_date_sk,d_date_sk]
                                                                FileSourceScanExecTransformer parquet spark_catalog.default.web_sales [ws_bill_customer_sk,ws_sold_date_sk]
                                                                  ReusedSubquery [d_date_sk] #2
                                                                InputIteratorTransformer
                                                                  InputAdapter
                                                                    ReusedExchange [d_date_sk] #6
                                                InputIteratorTransformer
                                                  InputAdapter
                                                    ColumnarExchange [cs_ship_customer_sk] #8
                                                      VeloxResizeBatches
                                                        WholeStageCodegenTransformer (12)
                                                          ProjectExecTransformer [cs_ship_customer_sk]
                                                            BroadcastHashJoinExecTransformer [cs_sold_date_sk,d_date_sk]
                                                              FileSourceScanExecTransformer parquet spark_catalog.default.catalog_sales [cs_ship_customer_sk,cs_sold_date_sk]
                                                                ReusedSubquery [d_date_sk] #2
                                                              InputIteratorTransformer
                                                                InputAdapter
                                                                  ReusedExchange [d_date_sk] #6
                                          InputIteratorTransformer
                                            InputAdapter
                                              ColumnarBroadcastExchange #9
                                                WholeStageCodegenTransformer (13)
                                                  ProjectExecTransformer [ca_address_sk]
                                                    FilterExecTransformer [ca_county,ca_address_sk]
                                                      FileSourceScanExecTransformer parquet spark_catalog.default.customer_address [ca_address_sk,ca_county]
                            InputIteratorTransformer
                              InputAdapter
                                ColumnarExchange [cd_demo_sk,cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count] #10
                                  VeloxResizeBatches
                                    WholeStageCodegenTransformer (15)
                                      ProjectExecTransformer [cd_demo_sk,cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count]
                                        FilterExecTransformer [cd_demo_sk]
                                          FileSourceScanExecTransformer parquet spark_catalog.default.customer_demographics [cd_demo_sk,cd_gender,cd_marital_status,cd_education_status,cd_purchase_estimate,cd_credit_rating,cd_dep_count,cd_dep_employed_count,cd_dep_college_count]
