You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@apex.apache.org by Devendra Tagare <de...@datatorrent.com> on 2016/03/23 18:41:04 UTC

Adding AvroFileInputOperator to Malhar

Hi All,

I am working on adding a concrete implementation for reading Avro container
files by extending the AbstractFileInputOperator & emitting Generic Records
based on the file schema.

This operator would be an input adapter and can work together with the Avro
to POJO operator to read an Avro container file, emit a generic record
which would then be converted to the user defined POJO.

Thanks,
Dev