如何扩展flink sql以实现延迟调用？

[casel.chen]

双流关联场景下，流A数据到达后并不马上和流B进行关联，而是经过设置一段时间后再关联，这种场景下如何用flink 
sql实现？如果当前不支持，需要怎样扩展flink sql呢？