In my use case I want to ingest into Rya through a NiFi pipeline so I put together a NiFi processor that facilitates ingest through Rya's API. It's nothing too fancy but it does work. I don't know how applicable it might be to other users. If there is interest I have no problems donating it to your project.
https://github.com/mtnfog/rya-ingest-nifi-processor Jeff
