org.apache.drill.exec.store.kafka

Class KafkaQueriesTest

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.KafkaQueriesTest

public class KafkaQueriesTest
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
KafkaQueriesTest()

Method Summary

Modifier and Type	Method and Description
void	testAvroResultCount()
void	testEscapeAnyChar()
void	testInformationSchema()
void	testMalformedRecords()
void	testNanInf()
void	testOneMessageTopic()
void	testPartitionMaxOffset()
void	testPartitionMinOffset()
void	testPhysicalPlanSubmission()
void	testPhysicalPlanSubmissionAvro()
void	testResultCount()
void	testSqlQueryOnInvalidTopic()

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

KafkaQueriesTest

public KafkaQueriesTest()

Method Detail

testSqlQueryOnInvalidTopic

public void testSqlQueryOnInvalidTopic()
                                throws Exception

Throws:

Exception

testResultCount

public void testResultCount()

testAvroResultCount

public void testAvroResultCount()

testPartitionMinOffset

public void testPartitionMinOffset()
                            throws Exception

Throws:

Exception

testPartitionMaxOffset

public void testPartitionMaxOffset()
                            throws Exception

Throws:

Exception

testInformationSchema

public void testInformationSchema()
                           throws Exception

Throws:

Exception

testPhysicalPlanSubmission

public void testPhysicalPlanSubmission()
                                throws Exception

Throws:

Exception

testPhysicalPlanSubmissionAvro

public void testPhysicalPlanSubmissionAvro()
                                    throws Exception

Throws:

Exception

testOneMessageTopic

public void testOneMessageTopic()
                         throws Exception

Throws:

Exception

testMalformedRecords

public void testMalformedRecords()
                          throws Exception

Throws:

Exception

testNanInf

public void testNanInf()
                throws Exception

Throws:

Exception

testEscapeAnyChar

public void testEscapeAnyChar()
                       throws Exception

Throws:

Exception