我正在寻找有关如何使用较新的 StreamInsight 2.1 反应式扩展模型创建动态查询的信息。具体来说,我想在 IQStreamable 中使用 CreatQuery() 方法或类似的方法(在 IQueryable 中)。在我正在创建的工作流中,这个新查询将作为常设查询插入到 StreamInsight 中。我做了很多研究,但没有找到解决方案。此外,大多数文档似乎都引用了现在的“遗留”适配器模型。任何帮助,将不胜感激。
问问题
60 次