In case of updatable stores for rdf streams, it makes senso to have a DataGen that periodically query the source considering new data to stream out.