请教下群里的大神,消息队列里只保留了2天的数据,实时表里需要补近7天的数据,怎么把hi #Flink

请教下群里的大神,消息队列里只保留了2天的数据,实时表里需要补近7天的数据,怎么把hive的数据先读到flink的state里,再去消费消息队列啊?#Flink

展开
收起
黄一刀 2020-08-21 21:30:42 2642 分享 版权
2 条回答
写回答
取消 提交回答
  • 未来https://www.aliyun.com/product/rocketmq?spm=5176.14414305.J_8058803260.385.3ec65960K5Guu8会提供分级存储,提供月级别的存储时长

    2021-03-19 22:34:19
    赞同 展开评论
  • state process api 或者把历史数据当初维表去关联

    2020-08-21 21:31:32
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理