Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Support for running multiple versions of the same component through additional versioning information provided in the NAR MANIFEST file
  • Introduced a record abstraction with controller services for reading and writing records from CSV, JSON, Avro, and Grok
  • Features/improvements related to Change Data Capture (CDC), including CaptureChangeMySQL, EnforceOrder, and PutDatabaseRecord processors, as well as a "Rollback on Failure" capability of some Put processors
  • Provided two additional implementations of the Provenance Event Repository: WriteAheadProvenanceRepository, which is designed to be much faster than the PersistentProvenanceRepository; and EncryptedWriteAheadProvenanceRepository, which is capable of encrypting (and decrypting) the Provenance Events so that they are never written out as plain text on disk
  • Added a new QueryRecord processor that allows SQL queries to be run over the contents of a FlowFile
  • Added a new ConvertRecord processor that is capable of converting data between different data formats, using the above-mentioned controller services
  • Added a new SplitRecord processor that is capable of splitting a large stream of record-oriented data into single records or smaller batches
  • Added new processors for publishing record-oriented data to Kafka and consuming record-oriented data from Kafka (PublishKafkaRecord_0_10 and ConsumeKafkaRecord_0_10)
  • Added new controller services for managing data schemas (AvroSchemaRegistry, HortonworksSchemaRegistry)

NiFi NAR Maven Plugin Version 1.2.0

...