Removes buffering for every single row
This commit is contained in:
parent
3a066fa9fe
commit
8477d4569a
@ -67,7 +67,7 @@ JsonFormat.prototype.handleQueryRow = function(row, result) {
|
||||
|
||||
this.buffer += (this.total_rows++ ? ',' : '') + JSON.stringify(row);
|
||||
|
||||
if (this.total_rows % (1||this.opts.bufferedRows || 1000)) {
|
||||
if (this.total_rows % (this.opts.bufferedRows || 1000)) {
|
||||
this.opts.sink.write(this.buffer);
|
||||
this.buffer = '';
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user