Member since
04-14-2020
4
Posts
0
Kudos Received
0
Solutions
04-17-2020
06:46 AM
Could you solve it?
... View more
04-16-2020
08:48 AM
I read some xml documents with this structure: <Object Attr1="..." Attr2="..." Attr3="..." /> <Object Attr1="..." Attr2="..." Attr3="..." /> .... .... .... <Object Attr1="..." Attr2="..." Attr3="..." /> And I need to convert them to parquet. I am trying with the ConvertRecord processor defining as Record Reader an XMLReader and as Record Writer an ParquetRecordSetWriter 1.11.4. The XMLReader has the property "Expect Records as Array" set to false and the property "Schema Registry" set to an AvroSchemaRegistry 1.11.4 where I defined the schema as: { "type" : "record", "name" : "Object", "namespace" : "Object", "fields" : [ { "name" : "Attr1", "type" : "string" }, { "name" : "Attr2", "type" : "string" }, { "name" : "Attr3", "type" : "string" } ] } How can I fix it?
... View more
Labels:
04-14-2020
09:44 AM
Is it possible to do something similar but receiving the Server, Port and Path where the files are? Because GetSFTP and ListSFTP can't receive any input
... View more
04-14-2020
09:30 AM
In a NiFi flow, I read a JSON file from a webservice that contains information about an SFTP server (Server, Port, path where I should look for files, User ). I need to fetch all the files that are in the path specified in this file. I can't just use the ListSFTP processor connected to FetchSFTP or the GetSFTP processor since they don't allow input connections. How could I do something like this in NiFi?
... View more
- Tags:
- NiFi
Labels: