This repository contains custom Apache Nifi processors.
It is a modified version of the original processor (v1.7.1). (original source on github)
- Converted the date objects formatted with EEE MMM dd HH:mm:ss zzz yyyy to yyyy-MM-dd HH:mm:ss.SSS to prevent any string to date conversion failure.
- Added new tags.
- Added properties to control the catalog and schema name prepending to the table name.
- Enabled expression language support for statement type property.
- Reads attribute "convertJSONToSQL.clearCache" from flowfile to clean the table meta info cache.
- Used null comparision operator in where statement.
- Removed the check of primary key meta info look up, so that it is always present.
It pushes a gauge type metric to Prometheus Push Gateway.