org.apache.drill.exec.store.http

Class TestHttpPlugin

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

org.apache.drill.exec.store.http.TestHttpPlugin

public class TestHttpPlugin
extends ClusterTest

Tests the HTTP Storage plugin. Since the plugin makes use of REST requests, this test class makes use of the okhttp3 MockWebServer to simulate a remote web server. There are two unit tests that make remote REST calls, however these tests are ignored by default.

The HTTP reader uses Drill's existing JSON reader class, so the unit tests focus on testing the plugin configurations rather than how well it parses the JSON as this is tested elsewhere.

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.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
TestHttpPlugin()

Method Summary

Modifier and Type	Method and Description
static void	setup()
void	simpleSpecificQuery()
void	simpleSpecificQueryWithParams()
void	simpleStarQuery() Evaluates the HTTP plugin with the results from an API that returns the sunrise/sunset times for a given lat/long and date.
void	simpleTestWithMockServer()
void	simpleTestWithMockServerWithParams()
void	specificTestWithMockServer()
void	testCsvResponse()
void	testEmptyContent()
void	testEmptyJSONObjectResponse()
void	testErrorResponse()
void	testHeaders()
void	testLimitPushdown()
void	testNullContent()
void	testPostWithMockServer()
void	testSerDe()
void	testSlowResponse()
void	testXmlResponse()
void	testZeroByteResponse()
void	verifyPluginConfig()
void	wildcardQueryWithParams() As above, but we return only the contents of results, and use filter push-down for the arguments.

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

TestHttpPlugin

public TestHttpPlugin()

Method Detail

setup

public static void setup()
                  throws Exception

Throws:

Exception

verifyPluginConfig

public void verifyPluginConfig()
                        throws Exception

Throws:

Exception

simpleStarQuery

public void simpleStarQuery()
                     throws Exception

Evaluates the HTTP plugin with the results from an API that returns the sunrise/sunset times for a given lat/long and date. API documentation is available here: https://sunrise-sunset.org/api The API returns results in the following format:

 {
       "results":
       {
         "sunrise":"7:27:02 AM",
         "sunset":"5:05:55 PM",
         "solar_noon":"12:16:28 PM",
         "day_length":"9:38:53",
         "civil_twilight_begin":"6:58:14 AM",
         "civil_twilight_end":"5:34:43 PM",
         "nautical_twilight_begin":"6:25:47 AM",
         "nautical_twilight_end":"6:07:10 PM",
         "astronomical_twilight_begin":"5:54:14 AM",
         "astronomical_twilight_end":"6:38:43 PM"
       },
        "status":"OK"
     }
 }

Throws:

Exception - Throws exception if something goes awry

wildcardQueryWithParams

public void wildcardQueryWithParams()
                             throws Exception

As above, but we return only the contents of results, and use filter push-down for the arguments.

Throws:

Exception

simpleSpecificQuery

public void simpleSpecificQuery()
                         throws Exception

Throws:

Exception

simpleSpecificQueryWithParams

public void simpleSpecificQueryWithParams()
                                   throws Exception

Throws:

Exception

testSerDe

public void testSerDe()
               throws Exception

Throws:

Exception

simpleTestWithMockServer

public void simpleTestWithMockServer()
                              throws Exception

Throws:

Exception

simpleTestWithMockServerWithParams

public void simpleTestWithMockServerWithParams()
                                        throws Exception

Throws:

Exception

testCsvResponse

public void testCsvResponse()
                     throws Exception

Throws:

Exception

testXmlResponse

public void testXmlResponse()
                     throws Exception

Throws:

Exception

testPostWithMockServer

public void testPostWithMockServer()
                            throws Exception

Throws:

Exception

specificTestWithMockServer

public void specificTestWithMockServer()
                                throws Exception

Throws:

Exception

testLimitPushdown

public void testLimitPushdown()
                       throws Exception

Throws:

Exception

testSlowResponse

public void testSlowResponse()
                      throws Exception

Throws:

Exception

testZeroByteResponse

public void testZeroByteResponse()
                          throws Exception

Throws:

Exception

testEmptyJSONObjectResponse

public void testEmptyJSONObjectResponse()
                                 throws Exception

Throws:

Exception

testNullContent

public void testNullContent()
                     throws Exception

Throws:

Exception

testEmptyContent

public void testEmptyContent()
                      throws Exception

Throws:

Exception

testErrorResponse

public void testErrorResponse()
                       throws Exception

Throws:

Exception

testHeaders

public void testHeaders()
                 throws Exception

Throws:

Exception