org.apache.drill.exec.physical.impl.TopN

Class TestTopNEmitOutcome

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.test.PhysicalOpUnitTestBase

org.apache.drill.exec.physical.impl.BaseTestOpBatchEmitOutcome

org.apache.drill.exec.physical.impl.TopN.TestTopNEmitOutcome

public class TestTopNEmitOutcome
extends BaseTestOpBatchEmitOutcome

Nested Class Summary

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

PhysicalOpUnitTestBase.BatchIterator, PhysicalOpUnitTestBase.MockExecutorFragmentContext, PhysicalOpUnitTestBase.MockPhysicalOperator

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

DrillTest.MemWatcher

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.BaseTestOpBatchEmitOutcome

emptyInputRowSet, inputContainer, inputContainerSv2, inputOutcomes, inputSchema, nonEmptyInputRowSet, outputRecordCount

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

classpathScan, dirTestWatcher, drillbitContext, drillConf, fragContext, opContext, opCreatorReg, operatorFixture, scanDecodeExecutor, scanExecutor

Fields inherited from class org.apache.drill.exec.ExecTest

c, optionManager

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

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestTopNEmitOutcome()

Method Summary

Modifier and Type	Method and Description
void	testRegularTopNWithEmptyDataSet()
void	testRegularTopNWithEmptyDataSetAndNoneOutcome()
void	testTopN_NonEmptyFirst_EmptyOKEmitOutcome() Verifies TopNBatch correctness for the case where it receives non-empty batch in build schema phase followed by empty batchs with OK and EMIT outcomes.
void	testTopN_WithEmptyNonEmptyBatchesAndOKOutcome() Tests for validating regular TopN behavior with no EMIT outcome
void	testTopNEmptyBatchEmitOutcome() Verifies that if TopNBatch receives empty batches with OK_NEW_SCHEMA and EMIT outcome then it correctly produces empty batches as output.
void	testTopNEmptyBatchFollowedByNonEmptyBatchEmitOutcome()
void	testTopNMultipleEMITOutcome()
void	testTopNMultipleEmptyBatchFollowedByNonEmptyBatchEmitOutcome()
void	testTopNMultipleInputToMultipleOutputBatch_LowerLimits()
void	testTopNMultipleInputToSingleOutputBatch()
void	testTopNMultipleOutputBatchWithLowerLimits() Verifies that if TopNBatch receives multiple non-empty record batch with EMIT outcome in between then it produces output for those input batch correctly.
void	testTopNNonEmptyBatchEmitOutcome() Verifies that if TopNBatch receives a RecordBatch with EMIT outcome post build schema phase then it produces output for those input batch correctly.
void	testTopNResetsAfterFirstEmitOutcome() Verifies that if TopNBatch receives multiple non-empty record batch with EMIT outcome in between then it produces output for those input batch correctly.

Methods inherited from class org.apache.drill.exec.physical.impl.BaseTestOpBatchEmitOutcome

afterTest, beforeTest, setUpBeforeClass

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

getJsonReadersFromBatchString, getJsonReadersFromInputFiles, getOpCreatorReg, getReaderListForJsonBatches, joinCond, legacyOpTestBuilder, mockFragmentContext, mockOpContext, opTestBuilder, ordering, parseExprs, setup, teardown

Methods inherited from class org.apache.drill.exec.ExecTest

clear, getLocalFileSystem, mockDrillbitContext, mockUsDateFormatSymbols, mockUtcDateTimeZone, parseExpr, setupOptionManager

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

TestTopNEmitOutcome

public TestTopNEmitOutcome()

Method Detail

testTopNEmptyBatchEmitOutcome

public void testTopNEmptyBatchEmitOutcome()

Verifies that if TopNBatch receives empty batches with OK_NEW_SCHEMA and EMIT outcome then it correctly produces empty batches as output. First empty batch will be with OK_NEW_SCHEMA and second will be with EMIT outcome.

testTopNNonEmptyBatchEmitOutcome

public void testTopNNonEmptyBatchEmitOutcome()

Verifies that if TopNBatch receives a RecordBatch with EMIT outcome post build schema phase then it produces output for those input batch correctly. The first output batch will always be returned with OK_NEW_SCHEMA outcome followed by EMIT with empty batch. The test verifies the output order with the expected baseline.

testTopNEmptyBatchFollowedByNonEmptyBatchEmitOutcome

public void testTopNEmptyBatchFollowedByNonEmptyBatchEmitOutcome()

testTopNMultipleEmptyBatchFollowedByNonEmptyBatchEmitOutcome

public void testTopNMultipleEmptyBatchFollowedByNonEmptyBatchEmitOutcome()

testTopNResetsAfterFirstEmitOutcome

public void testTopNResetsAfterFirstEmitOutcome()

Verifies that if TopNBatch receives multiple non-empty record batch with EMIT outcome in between then it produces output for those input batch correctly. In this case it receives first non-empty batch with OK_NEW_SCHEMA in buildSchema phase followed by an empty batch with EMIT outcome. For this combination it produces output for the record received so far along with EMIT outcome. Then it receives second non-empty batch with OK outcome and produces output for it differently. The test validates that for each output received the order of the records are correct

testTopN_NonEmptyFirst_EmptyOKEmitOutcome

public void testTopN_NonEmptyFirst_EmptyOKEmitOutcome()

Verifies TopNBatch correctness for the case where it receives non-empty batch in build schema phase followed by empty batchs with OK and EMIT outcomes.

testTopNMultipleOutputBatchWithLowerLimits

public void testTopNMultipleOutputBatchWithLowerLimits()

Verifies that if TopNBatch receives multiple non-empty record batch with EMIT outcome in between then it produces output for those input batch correctly. In this case it receives first non-empty batch with OK_NEW_SCHEMA in buildSchema phase followed by an empty batch with EMIT outcome. For this combination it produces output for the record received so far along with EMIT outcome. Then it receives second non-empty batch with OK outcome and produces output for it differently. The test validates that for each output received the order of the records are correct

testTopNMultipleEMITOutcome

public void testTopNMultipleEMITOutcome()

testTopNMultipleInputToSingleOutputBatch

public void testTopNMultipleInputToSingleOutputBatch()

testTopNMultipleInputToMultipleOutputBatch_LowerLimits

public void testTopNMultipleInputToMultipleOutputBatch_LowerLimits()

testTopN_WithEmptyNonEmptyBatchesAndOKOutcome

public void testTopN_WithEmptyNonEmptyBatchesAndOKOutcome()

Tests for validating regular TopN behavior with no EMIT outcome

testRegularTopNWithEmptyDataSet

public void testRegularTopNWithEmptyDataSet()

testRegularTopNWithEmptyDataSetAndNoneOutcome

public void testRegularTopNWithEmptyDataSetAndNoneOutcome()