nifi-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matt Burgess <>
Subject Re: Adding schema inference
Date Tue, 21 May 2019 18:07:02 GMT

Check AbstractRouteRecord, it uses the read-first-get-schema-read-rest
pattern. However for that snippet, it is the RecordReader that is
possibly updating the schema (currently the only thing that does this
is schema inference), then the RecordSetWriter is created using the
(possibly updated) schema. For your PR, you might need to update the
schema manually and then pass that into the
RecordSetWriterFactory.getSchema() call.

Now that I think of it, you might be the first to do this
automatic-schema-update-on-write thing (if you choose to do so). I
thought NIFI-5524 [1] had been implemented but apparently not.



On Tue, May 21, 2019 at 10:08 AM Mike Thomsen <> wrote:
> Matt left this suggestion:
> What would be a good example of that pattern if I wanted to update that PR
> and document the process for others?
> Thanks,
> Mike

View raw message