我对Nifi非常陌生,我尝试对SQL server执行SQL,其中包含多个表,并从每个表中选择属性。我们怎么才能在Nifi上表演呢。我看到“生成表获取”,它允许我提到“表名”和它的“哪里条款”。不确定,如果涉及多个表,我们如何执行复杂连接。
例子-
Select
a.col1,
a.col2,
b.col3,
b.col4,
c.col5,
c.col6
from a left outer join b
on a.colx=b.colx
inner join c
on a.coly = c.coly
where exists (some condition etc)
谢谢你,悉达多
是否有可能在NiFi中执行impala操作?
我已经设置了一个连接到黑斑羚的DBCPConnectionPool,我可以在ExecuteSQL处理器上很好地执行select语句。
现在我想知道(如果可能的话)如何执行
Alter Table "X" recover partitions;
在Apache NiFi中
我尝试用Nifi更新Oracle数据库中的一些DB列。
我有这么一部分的电路:
我对上一次PutDatabaserecord有意见
nifi_ml_nifi.1.rb4f8g690fro@KoshDomain | 2021-07-12 17:34:20,919 ERROR [Timer-Driven Process Thread-2] o.a.n.p.standard.PutDatabaseRecord PutDatabaseRecord[id=017a10b4-fe2c-1b89-f752-67545ebb8406] Failed to put Records to data
我创建了具有数据类型-dateTimeOffset值的单列表,并插入了一些值。
create table dto (dto datetimeoffset(7))
insert into dto values (GETDATE()) -- inserts date and time with 0 offset
insert into dto values (SYSDATETIMEOFFSET()) -- current date time and offset
insert into dto values ('20131114 08:54:00 +10:00') -- manua
我正在使用nifi与我们的web应用程序...we,希望配置侦听我们的web服务的listenhttp处理器。问题是,nifi中的http侦听器处理器中的配置是什么,以便当我们发出curl post请求时,此ListenHttp处理器将捕获更新。基本上我不明白我必须在基本路径中放什么(我必须放nifi add i.e. 还是我们的web应用程序服务URL??)什么是contentListener。我是否必须将我们的web应用程序端口号放在侦听端口中?在请求命令中,我必须在url部分中放入什么
curl --request POST 'http://(here i have to use
我希望Nifi首先读取数据库中的所有人,然后为每个人带来地址,而不是进行连接。我知道这不是最有效的方法,但我们有一些具体的原因。 'each person‘部分是使用SplitAvro或SplitJson processor解析的,但我如何获取当前person的ID并将其用作下一个ExecuteSQL processor中的参数? 我已经检查了一些与我想要的类似的东西,但是问题有点老了(how to pass values dynamically in Apache NiFi from executeSQL to SelectHiveQL) 然而,上面提出的解决方案似乎更像是对本应简
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中,我需要查找某些数据映射的外部CSV记录。注意,这个解码过程很复杂,所以它必须是一个自定义处理器。我知道可以设置外部CSVRecordLookupService,然后在CustomController中定义一个属性描述符,如下所示
public static final PropertyDescriptor CLIENT_LOOKUP_SERVICE =
new PropertyDescriptor.Builder()
.name("Client CSV L