Mysql
 sql >> Teknologi Basis Data >  >> RDS >> Mysql

menggunakan kembali hasil ekspresi pilih dalam klausa GROUP BY?

Ya, memang . Anda dapat membuatnya berfungsi di Spark SQL dengan 2 cara menggunakan kolom baru di GROUP BY dan ORDER BY klausa

Pendekatan 1 menggunakan subkueri :

SELECT timeHour, someThing FROM (SELECT  
      from_unixtime((starttime/1000)) AS timeHour
    , sum(...)                          AS someThing
    , starttime
FROM
    some_table) 
WHERE
    starttime >= 1000*unix_timestamp('2017-09-16 00:00:00')
      AND starttime <= 1000*unix_timestamp('2017-09-16 04:00:00')
GROUP BY
    timeHour
ORDER BY
    timeHour
LIMIT 10;

Pendekatan 2 menggunakan WITH // cara elegan :

-- create alias 
WITH table_aliase AS(SELECT  
      from_unixtime((starttime/1000)) AS timeHour
    , sum(...)                          AS someThing
    , starttime
FROM
    some_table)

-- use the same alias as table
SELECT timeHour, someThing FROM table_aliase
WHERE
    starttime >= 1000*unix_timestamp('2017-09-16 00:00:00')
      AND starttime <= 1000*unix_timestamp('2017-09-16 04:00:00')
GROUP BY
    timeHour
ORDER BY
    timeHour
LIMIT 10;

Alternatif menggunakan Spark DataFrame(wo SQL) API dengan Scala :

// This code may need additional import to work well

val df = .... //load the actual table as df

import org.apache.spark.sql.functions._

df.withColumn("timeHour", from_unixtime($"starttime"/1000))
  .groupBy($"timeHour")
  .agg(sum("...").as("someThing"))
  .orderBy($"timeHour")
  .show()

//another way - as per eliasah comment
df.groupBy(from_unixtime($"starttime"/1000).as("timeHour"))
  .agg(sum("...").as("someThing"))
  .orderBy($"timeHour")
  .show()


  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. PHP MySql dan geolokasi

  2. SQL untuk mengembalikan daftar bidang yang berisi data non-NULL

  3. Uji NULL di beberapa kolom di MySQL

  4. Kebuntuan menggunakan SELECT ... UNTUK UPDATE di MySQL

  5. Pemantauan Basis Data - Pemecahan Masalah Prometheus Dengan Dasbor SCUMM