sparksql 開(kāi)窗函數(shù)怎么用
1 回答
九州編程
TA貢獻(xiàn)1785條經(jīng)驗(yàn) 獲得超4個(gè)贊
row_number方法，相當(dāng)于groupTopN。分組排序應(yīng)用非常廣泛。
package com.dt.spark
import org.apache.spark.sql.hive.HiveContext
import org.apache.spark.{SparkContext, SparkConf}
object SparkSQLWindowFunctionOps {
def main(args:Array[String]) {
val conf: SparkConf = new SparkConf().setAppName("SparkSQLWindowFunctionOps").setMaster("spark://Master:7077")
val sc = new SparkContext(conf)
val hiveContext = new HiveContext(sc) //構(gòu)建SQL上下文！
- 1 回答
- 0 關(guān)注
- 1264 瀏覽
添加回答
舉報(bào)
0/150
提交
取消