Hello guys, I want to transform JSON to Parquet, i followed a tutorial and my current flow is functionally. My problem is that i need to create parquet schema's dynamically. Every schema needs to get generated reading attributes/content of the incoming flowfile. Putparquet processor uses a RecordReader. I found this processor called ScriptedReader but i have no idea about how i can generate a schema and use it for PutParquet processor. Does anyone now how to use it? Or, are there any alternatives about creating a schema dynamically for Putparquet processor? Thanks in advice. ... View more

Hello guys, i recently started using NiFi 1.5.0, i want to transfer some files from sftp to S3. I want to get the variables necessary for ListSFTP ( like ssh_key, username, ecc) from a DB fetching with executeSQL processor. I want to override the processor group variables with executeScript, do you have any ideas? Or is there a way to pass variables to ListSFTP dynamically? Thanks in advice ... View more