当前位置: 首页 > 知识库问答 >
问题:

如何在NIFI中设置QueryCassandra处理器的增量或最大值列?

苏高峰
2023-03-14

我在Nifi中使用QueryCassandra处理器从Cassandra中获取数据以摄取MSSql表。但是我的Cassandra查询总是重复运行,并且在Cassandra Nifi的处理器中我没有任何设置增量或最大值列的选项。如何使用增量Cassandra查询执行Nifi流?

共有1个答案

扈阳辉
2023-03-14

在撰写本文时,这仍然是一个悬而未决的问题。如果有一个用于Cassandra的JDBC驱动程序,您可以将其与QueryDatabaseTable一起使用来执行增量获取。

 类似资料:
  • 我有一组处理器来执行一些功能。 只要考虑一个例子,如果我有getfile,generateflowfile处理器通过cron触发整个工作流。在某些时候,我进入那个工作流不能确保处理器按照cron运行,因为它的整个处理在那个时候完成了。 谁能建议我最好的方法,以确保处理器的最后运行时间和它的处理属性?。

  • 有一个特定的处理器,正如下面提到的,我对它感兴趣,与1.2.0相比,1.5.0中有一个额外的特性,所以我想使用它。 我看到有两种方法。 以上处理器存储为nifi-standard-nar-x.x.x.nar-unpacked文件。所以只需从1.5.0复制Nar,并将其放在1.2.0上即可。在此之后,我不确定nifi是否会识别这个新的处理器版本? 上面的处理器是下面文件的一部分,因此从它中创建一个新

  • 问题内容: 我在本地计算机上使用WAMP,提交具有2000个输入字段的FORM(method =“ POST”)时,我只能读取1001 _POST变量。即使用Netbeans调试器,如果表单中有多个1001输入字段,我可以清楚地看到_POST大小始终为1001。 我使用此http://ideone.com/GAw14 Java代码生成具有N个输入字段的表单并进行了测试。 在另一台机器(WAMP)上

  • 我有一个存储时间跨度数据的表。该表的架构类似于: 我试图计算出每个记录id的开始和结束日期,即最小开始日期和最大结束日期。StartDate不可为null,所以我不需要担心这个问题,但我需要MAX(EndDate)来表示这是当前正在运行的时间跨度。 重要的是,我要保持EndDate的NULL值,并将其视为最大值。 最简单的尝试(如下)无法突出MIN和MAX将忽略NULLS的问题(来源:http:/

  • 问题内容: 我有一个搜索栏,并尝试在步骤1中将值从60设置为180,将第二个设置为190。 不管用。知道如何解决吗? 问题答案:

  • 我有一个Rest API的测试计划,其中有一个线程组和两个采样器。同时运行负载测试 线程数(用户):80 加速期:1 我得到"响应代码: 504响应消息:GATEWAY_TIMEOUT"在jmeta. 我观察到,当聚合图中的最大值达到60000ms时,所有响应都超时。需要采取哪些措施来防止超时问题。当我使用50个或更少的用户时,负载测试工作正常。