Currently we have Read API for destination plugins. This is mostly used by our testing framework.

One current issue is that in our testing we assume the order of read is the order of insertion but destination plugins don't have such requirements. We might need to change this API to read a specific ID rather then read everything by _cq_source_name column.

Other things to consider is potential future implementation of cursor where this might be needed.