Relevant reading: https://github.com/apache/nifi/tree/main/nifi-commons/nifi-record https://github.com/apache/nifi/tree/main/nifi-commons/nifi-record-path https://github.com/apache/nifi/tree/main/nifi-commons/nifi-schema-utils https://github.com/apache/nifi/tree/main/nifi-nar-bundles/nifi-standard-services https://github.com/apache/nifi/tree/main/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-service-api https://github.com/apache/nifi/tree/main/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle
Those paths are where you will find the implementation details for everything from the Record components to the core reader implementations. On Mon, May 15, 2023 at 8:54 AM Mike Thomsen <[email protected]> wrote: > You would need to create a new Maven project that has a root POM and two > modules (one for the JAR and one for the NAR). You can find examples of > that project structure in our repository or in a lot of community repos on > GitHub. > > From there, you'd implement (going on memory here without the JavaDocs) a > RecordReader and a RecordReaderFactory. For the Record objects themselves, > the basic implementation you can use for that is a MapRecord which is just > a wrapper around a Java Map with a Schema object associated with it. > > On Thu, May 11, 2023 at 10:29 AM Abhik Lodh <[email protected]> > wrote: > >> Hi, >> I am writing this mail because I wanted to create a custom Record Reader >> in NiFi that parses ASCII files (or any other currently unsupported file >> format) but I’m having a very hard time creating a custom controller >> service that does this while integrating with ConvertRecord, UpdateRecord >> and ValidateRecord just like other RecordReaders. >> >> Could anyone help me out with this? >> >> Thanks and regards, >> Abhik Lodh >> >
