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; }