diff --git a/lib/scanner.js b/lib/scanner.js
index 3c06a28..675636a 100644
--- a/lib/scanner.js
+++ b/lib/scanner.js
@@ -31,9 +31,13 @@ util.inherits(Scanner, Readable);
 Scanner.prototype.init = function(callback) {
   var encode, encoding, key, params;
   params = {};
-  if (params.batch == null) {
-    params.batch = 1000;
-  }
+  
+ // if (params.batch == null) {
+ //   params.batch = 1000;
+ // }
+ 
+  params.batch = !!( this.options.batch ) ? this.options.batch : 1000;
+  
   key = "/" + this.options.table + "/scanner";
   encoding = this.options.encoding === 'undefined' ? this.options.encoding : this.client.options.encoding;
   if (this.options.startRow) {