Apache Flink：如何使用SourceFunction以指定的时间间隔执行任务？

"
我需要我的flink作业以指定的时间间隔从数据库中提取记录并在处理后将其归档。我已经实现了SourceFunction来从数据库中获取所需的记录，并添加了SourceFunction作为StreamExecutionEnvironment的源。如何指定StreamExecutionEnvironment需要每隔10分钟使用SourceFunction从数据库中获取记录？

SourceFunction：

public class MongoDBSourceFunction implements SourceFunction>{

public void cancel() {
    // TODO Auto-generated method stub
}

public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext

> context) throws Exception {

    List<Book> books = getBooks();

    context.collect(books);

}

public List<Book> getBooks() {
    List<Book> books = new ArrayList<Book>();

    //fetch all books from database     
    return books;
}

}
处理器：

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class ArchiveJob {

public static void main(String[] args) {

    final StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();

    env.addSource(new MongoDBSourceFunction()).print();
}

}"