[teiid-commits] teiid SVN: r2230 - trunk/engine/src/main/java/org/teiid/query/util.

[teiid-commits at lists.jboss.org]

Author: shawkins
Date: 2010-06-14 12:35:03 -0400 (Mon, 14 Jun 2010)
New Revision: 2230

Modified:
   trunk/engine/src/main/java/org/teiid/query/util/CommandContext.java
Log:
fixing errant check in

Modified: trunk/engine/src/main/java/org/teiid/query/util/CommandContext.java
===================================================================
--- trunk/engine/src/main/java/org/teiid/query/util/CommandContext.java	2010-06-14 15:43:33 UTC (rev 2229)
+++ trunk/engine/src/main/java/org/teiid/query/util/CommandContext.java	2010-06-14 16:35:03 UTC (rev 2230)
@@ -32,6 +32,7 @@
 import org.teiid.api.exception.query.QueryProcessingException;
 import org.teiid.common.buffer.BufferManager;
 import org.teiid.core.TeiidComponentException;
+import org.teiid.core.types.Streamable;
 import org.teiid.core.util.ArgCheck;
 import org.teiid.query.QueryPlugin;
 import org.teiid.query.eval.SecurityFunctionEvaluator;
@@ -78,6 +79,8 @@
 	    /** Indicate whether statistics should be collected for relational node processing*/
 	    private boolean collectNodeStatistics;
 	    
+	    private int streamingBatchSize = Streamable.STREAMING_BATCH_SIZE_IN_BYTES;
+	    
 	    private Random random = null;
 	    
 	    private SecurityFunctionEvaluator securityFunctionEvaluator;
@@ -271,6 +274,15 @@
         return this.globalState.collectNodeStatistics;
     }
     
+	public int getStreamingBatchSize() {
+		return globalState.streamingBatchSize;
+	}
+
+	public void setStreamingBatchSize(int streamingBatchSize) {
+		this.globalState.streamingBatchSize = streamingBatchSize;
+	}
+
+    
     public int getConnectorBatchSize() {
         return this.globalState.connectorBatchSize;
     }