org.apache.drill.exec.store.kafka

Class MessageIteratorTest

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

org.apache.drill.exec.store.kafka.KafkaTestBase

org.apache.drill.exec.store.kafka.MessageIteratorTest

public class MessageIteratorTest
extends KafkaTestBase

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.exec.store.kafka.KafkaTestBase

storagePluginConfig

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

client, cluster, dirTestWatcher

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

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
MessageIteratorTest()

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
void	setUp()
void	testShouldReturnMessage1()
void	testShouldReturnMessage2()
void	testShouldReturnTrueAsKafkaHasMessages()
void	testWhenPollTimeOutIsTooLess()

Methods inherited from class org.apache.drill.exec.store.kafka.KafkaTestBase

initKafkaStoragePlugin, runKafkaSQLVerifyCount, setUpBeforeClass, tearDownKafkaTestBase, testSql

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

getFile, queryBuilder, run, runAndLog, runAndPrint, runAndPrint, shutdown, startCluster, testBuilder

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

MessageIteratorTest

public MessageIteratorTest()

Method Detail

setUp

public void setUp()

cleanUp

public void cleanUp()

testWhenPollTimeOutIsTooLess

public void testWhenPollTimeOutIsTooLess()

testShouldReturnTrueAsKafkaHasMessages

public void testShouldReturnTrueAsKafkaHasMessages()

testShouldReturnMessage1

public void testShouldReturnMessage1()

testShouldReturnMessage2

public void testShouldReturnMessage2()