org.apache.drill.exec.store.elasticsearch

Class ElasticSearchQueryTest

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

org.apache.drill.exec.store.elasticsearch.ElasticSearchQueryTest

public class ElasticSearchQueryTest
extends ClusterTest

Nested Class Summary

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

DrillTest.MemWatcher

Field Summary

Fields

Modifier and Type	Field and Description
static RestHighLevelClient	restHighLevelClient

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
ElasticSearchQueryTest()

Method Summary

Modifier and Type	Method and Description
static void	cleanUp()
static void	init()
void	testAggregate()
void	testAggregateWithGroupBy()
void	testJoin()
void	testJoinWithFileTable()
void	testLimitWithSort()
void	testLiteralWithAggregateAndGroupBy()
void	testSelectAll()
void	testSelectAllFiltered()
void	testSelectAllWithLimitAndSort()
void	testSelectColumns()
void	testSelectColumnsFiltered()
void	testSelectColumnsUnsupportedAggregate()
void	testSelectColumnsUnsupportedFilter()
void	testSelectColumnsUnsupportedProject()
void	testSelectIntLiterals()
void	testSelectLiterals()
void	testSelectLiteralWithStar()
void	testSelectNonExistingColumn()
void	testSelectNonExistingSubSchema()
void	testSelectNonExistingTable()
void	testSingleColumn()
void	testWithProvidedSchema()

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

Field Detail

restHighLevelClient

public static RestHighLevelClient restHighLevelClient

Constructor Detail

ElasticSearchQueryTest

public ElasticSearchQueryTest()

Method Detail

init

public static void init()
                 throws Exception

Throws:

Exception

cleanUp

public static void cleanUp()
                    throws IOException

Throws:

IOException

testSelectAll

public void testSelectAll()
                   throws Exception

Throws:

Exception

testSelectColumns

public void testSelectColumns()
                       throws Exception

Throws:

Exception

testSelectAllFiltered

public void testSelectAllFiltered()
                           throws Exception

Throws:

Exception

testSelectColumnsFiltered

public void testSelectColumnsFiltered()
                               throws Exception

Throws:

Exception

testSelectColumnsUnsupportedFilter

public void testSelectColumnsUnsupportedFilter()
                                        throws Exception

Throws:

Exception

testSelectColumnsUnsupportedProject

public void testSelectColumnsUnsupportedProject()
                                         throws Exception

Throws:

Exception

testSelectColumnsUnsupportedAggregate

public void testSelectColumnsUnsupportedAggregate()
                                           throws Exception

Throws:

Exception

testLimitWithSort

public void testLimitWithSort()
                       throws Exception

Throws:

Exception

testSelectAllWithLimitAndSort

public void testSelectAllWithLimitAndSort()
                                   throws Exception

Throws:

Exception

testSingleColumn

public void testSingleColumn()
                      throws Exception

Throws:

Exception

testJoin

public void testJoin()
              throws Exception

Throws:

Exception

testJoinWithFileTable

public void testJoinWithFileTable()
                           throws Exception

Throws:

Exception

testAggregate

public void testAggregate()
                   throws Exception

Throws:

Exception

testAggregateWithGroupBy

public void testAggregateWithGroupBy()
                              throws Exception

Throws:

Exception

testSelectNonExistingColumn

public void testSelectNonExistingColumn()
                                 throws Exception

Throws:

Exception

testSelectLiterals

public void testSelectLiterals()
                        throws Exception

Throws:

Exception

testSelectIntLiterals

public void testSelectIntLiterals()
                           throws Exception

Throws:

Exception

testSelectLiteralWithStar

public void testSelectLiteralWithStar()
                               throws Exception

Throws:

Exception

testLiteralWithAggregateAndGroupBy

public void testLiteralWithAggregateAndGroupBy()
                                        throws Exception

Throws:

Exception

testSelectNonExistingTable

public void testSelectNonExistingTable()
                                throws Exception

Throws:

Exception

testSelectNonExistingSubSchema

public void testSelectNonExistingSubSchema()
                                    throws Exception

Throws:

Exception

testWithProvidedSchema

public void testWithProvidedSchema()
                            throws Exception

Throws:

Exception