Flink日期减去24小时 怎么实现？需要保留时分秒

在Flink中，可以使用DateTime类和TimeUnit枚举来实现日期减去24小时的操作。以下是一个示例：

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.util.Collector;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.concurrent.TimeUnit;

public class FlinkSubtract24Hours {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        DataStream<String> input = env.fromElements("2022-01-01 12:00:00");

        DataStream<String> output = input.map(new MapFunction<String, String>() {
            @Override
            public String map(String value) throws Exception {
                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
                LocalDateTime dateTime = LocalDateTime.parse(value, formatter);
                LocalDateTime newDateTime = dateTime.minus(1, TimeUnit.HOURS);
                return newDateTime.format(formatter);
            }
        });

        output.print();

        env.execute("Flink Subtract 24 Hours");
    }
}

在这个示例中，我们首先创建了一个StreamExecutionEnvironment，然后从输入数据流中读取一个字符串值。接下来，我们使用map函数将字符串值转换为LocalDateTime对象，然后使用minus方法减去24小时。最后，我们将结果转换回字符串并输出。

TIMESTAMPADD(HOUR, -24, ts) 这个试试呢。此回答整理自钉群“实时计算Flink产品交流群”

在Apache Flink中，你可以使用内置的时间函数和算术运算符来实现日期减去24小时。这里有一个示例，展示了如何使用Flink SQL进行这个操作：

-- 假设我们有一个名为orders的表，其中包含一个名为order_time的TIMESTAMP类型列

-- 减去24小时，并保留时分秒
SELECT order_time - INTERVAL '1' DAY AS new_order_time
FROM orders;

在这个例子中，我们使用了INTERVAL '1' DAY来表示24小时的时间间隔。这将从order_time列中减去24小时，同时保留原始的时分秒。

请注意，Flink中的时间处理可能依赖于底层数据库或数据源对时间戳的支持。在某些情况下，你可能需要根据具体的数据源和环境调整你的查询。

如果你正在使用的是其他类型的日期格式（如字符串），那么你可能需要先将它们转换为TIMESTAMP类型，然后再执行减法操作。例如，如果你的日期是以"yyyy-MM-dd HH:mm:ss"格式存储的字符串，可以使用以下查询：

-- 假设我们有一个名为orders的表，其中包含一个名为order_time的VARCHAR类型列

-- 将字符串转换为TIMESTAMP，然后减去24小时
SELECT TO_TIMESTAMP(order_time, 'yyyy-MM-dd HH:mm:ss') - INTERVAL '1' DAY AS new_order_time
FROM orders;