jena streamRDF connector

[hochgi]

would love to see an akka streams integration with:
https://jena.apache.org/documentation/io/streaming-io.html
I haven't worked up all the details yet,
assuming a wrapper class for

base(String base) 
prefix(String prefix, String iri)
quad(Quad quad)
triple(Triple triple)

( taken from https://jena.apache.org/documentation/javadoc/arq/org/apache/jena/riot/system/StreamRDF.html )
like:

trait RDFEvent
case class Base(base: String) extends RDFEvent
case class Prefix(prefix: String, iri: String) extends RDFEvent
case class Quad(quad: Quad) extends RDFEvent
case class Triple(triple: Triple) extends RDFEvent

I guess such connector should at least provide:

• Flow[RDFEvent,ByteString] to format RDF data as any flavour available.
• Flow[ByteString,RDFEvent] to parse RDF in a streaming fashion. a Sink and Source constructs can also be used.

[patriknw]

Sounds great :+1:

[wmaroy]

@hochgi I'm also interested in this. Did someone do any follow up work on this?

[hochgi]

@wmaroy not that I'm aware of. It's on my "todo list" though. Not making any promises, but will try and clear myself some time to work on it, now that I know others are interested.