作者热门文章
- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试使用 Luwak 创建自定义处理器Lucene 索引器,因此我可以对传入流文件运行查询。我试图找出更新 Luwak 监视器内部存在的查询索引的最佳方法(下面的示例代码)。
编辑 - 更多使用上下文
通过更新,我的意思是允许外部用户添加/更新/删除针对传入流文件运行的查询。我们将从一组固定的查询开始,但随后希望允许一个或多个用户能够更改针对传入消息执行的查询。这就是挑战,改变正在执行的查询。
我还应该考虑其他选择吗?如果有 10k 个查询,则更新查询似乎需要大约 20 秒。这种情况很可能很少见,但重新加载/启动时间是我正在考虑的事情。
我考虑过的选项:
实例化监视器:
Monitor monitor = new Monitor(new LuceneQueryParser("field"), new TermFilteredPresearcher());
添加查询 - 我正在尝试优化的内容:
//Add queries to the monitor
for (Map.Entry<String, String> entry : bucketList.entrySet()) {
MonitorQuery q = new MonitorQuery(entry.getKey(),entry.getValue());
monitor.update(q);
}
最佳答案
当您的处理器启动时,您可以启动一个后台计时器线程,该线程定期构建一个新监视器,然后替换处理器正在使用的监视器。
您可能希望在处理器中创建一个成员变量,例如:
AtomicReference<Monitor> monitorHolder = new AtomicReference<Monitor>();
然后在@OnScheduled中,您可以构建初始监视器并将其设置在支架中。
然后在 onTrigger 中你总是首先获得监视器:
Monitor localMonitor = monitorHolder.get();
然后在后台线程中可以调用monitorHolder.set(newMonitor),这不会影响处理器当前的执行,但会在下次调用onTrigger时生效。
关于java - NiFi - 更新处理器中的 Luwak (Lucene) 索引,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47005634/
我正在尝试使用 Luwak 创建自定义处理器Lucene 索引器,因此我可以对传入流文件运行查询。我试图找出更新 Luwak 监视器内部存在的查询索引的最佳方法(下面的示例代码)。 编辑 - 更多使用
我是一名优秀的程序员,十分优秀!