假设我在datetime(2021-11-02 05:05:00)精确地运行以下查询 MyTable | where ingestion_time() between (datetime(2021-11是否可以保证ingestion_time()在此时间窗口内的所有行都已作为表的一部分可用?通过实验,我发现在任何给定时间后大约10分钟,最近5分钟时间窗口的数据仍然在流动。因此,在本例中,假设即使在datetime(2021-11-02 05:10:00),新行仍然填充到表中,ingestion_t
我们有一个nifi模板,用于从关系SQL Server DB中提取数据,并将表的每一行作为Marklogic中的文档进行摄取。现在,我们希望在组合中添加DH,并将nifi模板作为注入流的一部分运行,以填充staging DB。将nifi模板作为摄取流的一部分进行调用的推荐方法是什么?是否有其他推荐的方法来从关系数据库中提取数据,并在注入流期间将其注入Marklogic? 谢谢你的帮助。