org.apache.nifi.processors.ignite.cache

Class ITPutIgniteCache

java.lang.Object

org.apache.nifi.processors.ignite.cache.ITPutIgniteCache

public class ITPutIgniteCache
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ITPutIgniteCache()

Method Summary

Modifier and Type	Method and Description
static void	setUp()
static void	teardown()
void	testPutIgniteCacheOnTriggerFileConfigurationOneFlowFile()
void	testPutIgniteCacheOnTriggerNoConfigurationTwoFlowFile()
void	testPutIgniteCacheOnTriggerNoConfigurationTwoFlowFileStopAndStart2Times()

Methods inherited from class java.lang.Object

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

Constructor Detail

ITPutIgniteCache

public ITPutIgniteCache()

Method Detail

setUp

public static void setUp()
                  throws java.io.IOException

Throws:

java.io.IOException

teardown

public static void teardown()

testPutIgniteCacheOnTriggerFileConfigurationOneFlowFile

public void testPutIgniteCacheOnTriggerFileConfigurationOneFlowFile()
                                                             throws java.io.IOException,
                                                                    java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testPutIgniteCacheOnTriggerNoConfigurationTwoFlowFile

public void testPutIgniteCacheOnTriggerNoConfigurationTwoFlowFile()
                                                           throws java.io.IOException,
                                                                  java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testPutIgniteCacheOnTriggerNoConfigurationTwoFlowFileStopAndStart2Times

public void testPutIgniteCacheOnTriggerNoConfigurationTwoFlowFileStopAndStart2Times()
                                                                             throws java.io.IOException,
                                                                                    java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException