org.apache.nifi.processors.elasticsearch

Class TestFetchElasticsearchHttp

java.lang.Object

org.apache.nifi.processors.elasticsearch.TestFetchElasticsearchHttp

public class TestFetchElasticsearchHttp
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestFetchElasticsearchHttp()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	teardown()
void	testFetchElasticsearchBasic() Tests basic ES functionality against a local or test ES cluster
void	testFetchElasticsearchBatch()
void	testFetchElasticsearchOnTrigger()
void	testFetchElasticsearchOnTriggerEL()
void	testFetchElasticsearchOnTriggerNoType()
void	testFetchElasticsearchOnTriggerQueryParameter()
void	testFetchElasticsearchOnTriggerWithDocNotFound()
void	testFetchElasticsearchOnTriggerWithFields()
void	testFetchElasticsearchOnTriggerWithServerErrorRetry()
void	testFetchElasticsearchOnTriggerWithServerFail()
void	testFetchElasticsearchOnTriggerWithServerFailNoIncomingFlowFile()
void	testFetchElasticsearchWithBadHosts()
void	testSetupSecureClient()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestFetchElasticsearchHttp

public TestFetchElasticsearchHttp()

Method Detail

setUp

public void setUp()
           throws java.io.IOException

Throws:

java.io.IOException

teardown

public void teardown()

testFetchElasticsearchOnTriggerEL

public void testFetchElasticsearchOnTriggerEL()
                                       throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTrigger

public void testFetchElasticsearchOnTrigger()
                                     throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTriggerNoType

public void testFetchElasticsearchOnTriggerNoType()
                                           throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTriggerWithFields

public void testFetchElasticsearchOnTriggerWithFields()
                                               throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTriggerWithDocNotFound

public void testFetchElasticsearchOnTriggerWithDocNotFound()
                                                    throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTriggerWithServerErrorRetry

public void testFetchElasticsearchOnTriggerWithServerErrorRetry()
                                                         throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTriggerWithServerFail

public void testFetchElasticsearchOnTriggerWithServerFail()
                                                   throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchOnTriggerWithServerFailNoIncomingFlowFile

public void testFetchElasticsearchOnTriggerWithServerFailNoIncomingFlowFile()
                                                                     throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchWithBadHosts

public void testFetchElasticsearchWithBadHosts()
                                        throws java.io.IOException

Throws:

java.io.IOException

testSetupSecureClient

public void testSetupSecureClient()
                           throws java.lang.Exception

Throws:

java.lang.Exception

testFetchElasticsearchOnTriggerQueryParameter

public void testFetchElasticsearchOnTriggerQueryParameter()
                                                   throws java.io.IOException

Throws:

java.io.IOException

testFetchElasticsearchBasic

public void testFetchElasticsearchBasic()

Tests basic ES functionality against a local or test ES cluster

testFetchElasticsearchBatch

public void testFetchElasticsearchBatch()
                                 throws java.io.IOException

Throws:

java.io.IOException