java - flink table api 日 年 月 提取

Question

我如何从 frilk table api 中提取一天的时间和时间

final Table select = transactions
                .window(Tumble.over(lit(1).hour()).on($("transaction_time")).as("log_ts"))
                .groupBy($("transaction_time").year(),$("transaction_time").month(),$("transaction_time").day())
                .select(
                        $("account_id"),
                        $("log_ts").start().as("log_ts"),
                        $("amount").sum().as("amount") );
        return select;

我想根据每一天进行分组。示例记录

演员（2020-01-01T00:12，时间戳（3））

上面的 group by 是我正在尝试的，但它显示以下错误

org.apache.flink.table.api.ValidationException：年月间隔的无效常量：transaction_time

标签： javasqlapache-flinkflink-streamingflink-sql