#INCLUDE ${WORKSPACEPROJECT}/GC_BASE_CONSTANTS.qry

#IFSRCNDEF taxi
#INCLUDE ${WORKSPACEPROJECT}/Source.qry
#ENDIF
#PARALLELIZATION INTER_OPERATOR 4 AUTO
#INTEROPERATORPARALLELIZATION countDropOff 64 10000 GroupedAggregateMultithreadedTransformationStrategy

#DOREWRITE false
#PARSER PQL
#RUNQUERY

prepare = PROJECT({
              attributes = ['dropoff_cell_x','dropoff_cell_y', 'count']            
            },
            SELECT({
                predicate = 'count > 1'
              },
              AGGREGATE({
              	  id = "countDropOff",
                  aggregations = [['COUNT', 'dropoff_cell_x', 'count']],
                  group_by = ['dropoff_cell_x','dropoff_cell_y'],
                  dumpatvaluecount = 1000              
                },
                taxi
              )          
            )          
          )