org.apache.drill.exec.physical.resultSet.impl

Class TestResultSetLoaderLimits

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.SubOperatorTest

org.apache.drill.exec.physical.resultSet.impl.TestResultSetLoaderLimits

public class TestResultSetLoaderLimits
extends SubOperatorTest

Tests of the row limit functionality of the result set loader. The row limit is set up front and has a default value. Because Drill must discover data structure as it reads, the result set loader also allows changing the row limit between batches (perhaps Drill discovers that rows are much narrower or wider than expected.)

The tests here are independent of the tests for vector allocation (which does, in fact, depend on the row count) and vector overflow (which an occur when the row limit turns out to be too large.)

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.test.DrillTest

DrillTest.MemWatcher

Field Summary

Fields inherited from class org.apache.drill.test.SubOperatorTest

dirTestWatcher, fixture

Fields inherited from class org.apache.drill.test.DrillTest

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestResultSetLoaderLimits()

Method Summary

Modifier and Type	Method and Description
void	testCustomRowLimit() Verify that the caller can set a row limit lower than the default.
void	testDynamicLimit() Test that the row limit can change between batches.
void	testRowLimit() Verify that the writer stops when reaching the row limit.

Methods inherited from class org.apache.drill.test.SubOperatorTest

classSetup, classTeardown

Methods inherited from class org.apache.drill.test.DrillTest

escapeJsonString, finishDrillTest, initDrillTest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestResultSetLoaderLimits

public TestResultSetLoaderLimits()

Method Detail

testRowLimit

public void testRowLimit()

Verify that the writer stops when reaching the row limit. In this case there is no look-ahead row.

testCustomRowLimit

public void testCustomRowLimit()

Verify that the caller can set a row limit lower than the default.

testDynamicLimit

public void testDynamicLimit()

Test that the row limit can change between batches.