我正在尝试根据数据库中可用的某些规则从一个原始数据流中创建新的数据流。一旦我开始了flink工作，如果我需要根据数据库中更新的条目创建一个新的数据流，我该如何实现这一点。因此，这里我不想重新启动flink作业，而是在运行时动态创建新的数据流，并将其添加到执行dag中。