Skip to content

Conversation

scchy
Copy link

@scchy scchy commented Jan 3, 2020

sales_SQL = spark.sql("""SELECT   city, year, sum(amount) as amount 
                                  ,GROUPING_ID(city, year) GFLG
                           FROM   sales_tbl
                       GROUP BY   ROLLUP(city, year)
                         HAVING   3 != GROUPING_ID(city, year) 
                       ORDER BY   city DESC NULLS LAST, year ASC NULLS LAST
                    """)

    sales_SQL = spark.sql("""SELECT   city, year, sum(amount) as amount 
                                      ,GROUPING_ID(city, year) GFLG
                               FROM   sales_tbl
                           GROUP BY   ROLLUP(city, year)
                             HAVING   3 != GROUPING_ID(city, year) 
                           ORDER BY   city DESC NULLS LAST, year ASC NULLS LAST
                        """)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant