Streaming support

[jorgebay]

Provide streaming support to avoid storing in memory large buffers when retrieving info from Cassandra.

Use cases

• Retrieve large blobs and stream it.
• Retrieve large sets of rows and use them before the all the rows had been received.

The resulting stream is readable and buffers if no consumer is pulling data from it.

Sample

//with Express
app.get('/img/big.png', function(req, res) {
  var query = 'SELECT id, big_blob FROM table1 WHERE ID=1';
  //pass the stream as an argument
  client.executeToStream(query, function (err, row, blobStream) {
    //you can access the row values
    var id = row.get('id');
    //you can access the stream.Readable that streams data of big_blob column 
    //as soon as is received
    blobStream.pipe(res);
  });
})

Use cases: queries to stream

//one *BIG* field in one row
query = 'SELECT id, big_blog FROM table1 WHERE ID=?'

//some "context" non binary fields, multiple rows
query = 'SELECT id, key, text, big_blob FROM table1';

//stream just rows (added Sep 11th)
query = 'SELECT * FROM table1';

[ottes]

I'm interested too! Have to receive a lot complete rows and that would blow out my memory

[jorgebay]

It took a while but its finished!!!