import org.apache.spark.sql.functions._
df.withColumn("window", window(current_timestamp(), "15 minutes"))On Mon, Sep 11, 2017 at 3:03 AM, 张万新 <kevinzwx1...@gmail.com> wrote: > Hi, > > In structured streaming how can I add a column to a dataset with current > system time aligned with 15 minutes? > > Thanks. >
