Hello everyone,
It would be great if you can help me implementing this use-case
- Is there any way (NiFi processor) to use *an attribute (field/ column)
value for partitioning* when writing the final FlowFile to HDFS/ other
storage.
- Earlier we were using simple system date (
*/year=${now():format('yyyy')}/month=${now():format('MM')}/day=${now():format('dd')}/*)
for this but that doesn't make sense when we consume old data from Kafka
and want to partition on original date (a date field inside Kafka message)
Thank you!
______________________
*Kind Regards,*
*Anshuman Ghosh*
*Contact - +49 179 9090964*
