我试图通过SparkSQL选择周日记录的所有记录.我有以下尝试,但徒劳无功.
SELECT * FROM mytable WHERE DATEPART(WEEKDAY, create_time) = 0
SELECT * FROM mytable WHERE strftime("%w", create_time) = 0
Run Code Online (Sandbox Code Playgroud)
如何在SparkSQL中获取星期几?
我有一个日期列,它是数据帧中的字符串,采用 2017-01-01 12:15:43 时间戳格式。
现在我想使用 dataframe 而不是 Spark sql 从该列获取工作日编号(1 到 7)。
像下面这样
df.select(weekday(col("colname")))
Run Code Online (Sandbox Code Playgroud)
我在 python 和 sql 中找到了一个,但在 scala 中没有找到。有谁能帮我解决这个问题吗
在 sql 上下文中
sqlContext.sql("select date_format(to_date('2017-01-01'),'W') as week")
Run Code Online (Sandbox Code Playgroud)