flink 1.14 Hybrid Source切换source时机问题

[casel.chen]

我有一个Hybrid Source切换时机问题: 
在Hive+Kafka场景下，假如Kafka保留数据时长(retension)是1天，为了实现无缝衔接，我需要从Hive消费历史存量数据直到距离当前时间小于1天时才切换到kafka
 source，假设Hive中有字段表示处理时间的话，请问目前Flink Hybrid Source支持这种用法吗？如果支持的话程序应该要怎么写？谢谢！