search

aliyun / aliyun-log-flink-connector

flink log connector
Apache License 2.0
58 stars 23 forks source link

消费指定时间段的数据 #38

Open winve opened 4 years ago

winve commented 4 years ago

如何消费指定时间段数据？比如今天想消费昨天2点 到 3点的数据，如何处理

liketic commented 4 years ago

@winve 我们可以加一个结束时间

winve commented 4 years ago

@liketic 在哪里可以配置结束时间呢？查看了 FlinkLogConsumer ，没有可以添加结束时间的属性

liketic commented 4 years ago

@winve https://github.com/aliyun/aliyun-log-flink-connector/pull/40/files 我加上了，尽快发布

winve commented 4 years ago

赞，什么时候可以发布？

liketic commented 4 years ago

@winve 已经发布0.1.21 ，欢迎试用

fenglove commented 4 years ago

你好，使用了 0.1.21 版本的包，指定start time 和 stop time，程序消费完数据后，如何自动停止呢？