Implement incremental streaming from the data base