秩（）在星火SQL

Question

功能的使用需要使用rank()

我已經從dataset..need提取的列做排名一些指點。

Dataset<Row> inputCol= inputDataset.apply("Colname");  
Dataset<Row> DSColAwithIndex=inputDSAAcolonly.withColumn("df1Rank", rank()); 

DSColAwithIndex.show(); 

我可以排序的列，然後添加一個索引列也獲得軍銜......但奇怪的已知語法和rank()

Answer 1

Window規範的使用需要rank()

val w = org.apache.spark.sql.expressions.Window.orderBy("date") //some spec  

val leadDf = inputDSAAcolonly.withColumn("df1Rank", rank().over(w)) 

被指定

編輯：答案的Java版本，使用Java

import org.apache.spark.sql.expressions.WindowSpec; 
WindowSpec w = org.apache.spark.sql.expressions.Window.orderBy(colName); 
Dataset<Row> leadDf = inputDSAAcolonly.withColumn("df1Rank", rank().over(w)); 

OP