org.apache.nifi.hbase

Class TestPutHBaseJSON

java.lang.Object

org.apache.nifi.hbase.TestPutHBaseJSON

public class TestPutHBaseJSON
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_COLUMN_FAMILY
static java.lang.String	DEFAULT_ROW
static java.lang.String	DEFAULT_TABLE_NAME
static java.lang.Long	DEFAULT_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
TestPutHBaseJSON()

Method Summary

Modifier and Type	Method and Description
void	testAllElementsAreNullOrArrays()
void	testCustomValidate()
void	testELWithExtractedRowId()
void	testELWithProvidedRowId()
void	testInvalidJson()
void	testMultipleJsonDocsRouteToFailure()
void	testNestedDocWithTextStrategy()
void	testNullAndArrayElementsWithFailureStrategy()
void	testNullAndArrayElementsWithIgnoreStrategy()
void	testNullAndArrayElementsWithTextStrategy()
void	testNullAndArrayElementsWithWarnStrategy()
void	testSingJsonDocAndExtractedRowId()
void	testSingJsonDocAndExtractedRowIdMissingField()
void	testSingleJsonDocAndProvidedRowId()
void	testSingleJsonDocAndProvidedRowIdwithNonString()
void	testTimestamp()
void	testTimestampWithEL()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TABLE_NAME

public static final java.lang.String DEFAULT_TABLE_NAME

See Also:

Constant Field Values

DEFAULT_ROW

public static final java.lang.String DEFAULT_ROW

See Also:

Constant Field Values

DEFAULT_COLUMN_FAMILY

public static final java.lang.String DEFAULT_COLUMN_FAMILY

See Also:

Constant Field Values

DEFAULT_TIMESTAMP

public static final java.lang.Long DEFAULT_TIMESTAMP

Constructor Detail

TestPutHBaseJSON

public TestPutHBaseJSON()

Method Detail

testCustomValidate

public void testCustomValidate()
                        throws InitializationException

Throws:

InitializationException

testSingleJsonDocAndProvidedRowId

public void testSingleJsonDocAndProvidedRowId()
                                       throws java.io.IOException,
                                              InitializationException

Throws:

java.io.IOException

InitializationException

testSingleJsonDocAndProvidedRowIdwithNonString

public void testSingleJsonDocAndProvidedRowIdwithNonString()
                                                    throws java.io.IOException,
                                                           InitializationException

Throws:

java.io.IOException

InitializationException

testSingJsonDocAndExtractedRowId

public void testSingJsonDocAndExtractedRowId()
                                      throws java.io.IOException,
                                             InitializationException

Throws:

java.io.IOException

InitializationException

testSingJsonDocAndExtractedRowIdMissingField

public void testSingJsonDocAndExtractedRowIdMissingField()
                                                  throws java.io.IOException,
                                                         InitializationException

Throws:

java.io.IOException

InitializationException

testMultipleJsonDocsRouteToFailure

public void testMultipleJsonDocsRouteToFailure()
                                        throws java.io.IOException,
                                               InitializationException

Throws:

java.io.IOException

InitializationException

testELWithProvidedRowId

public void testELWithProvidedRowId()
                             throws java.io.IOException,
                                    InitializationException

Throws:

java.io.IOException

InitializationException

testELWithExtractedRowId

public void testELWithExtractedRowId()
                              throws java.io.IOException,
                                     InitializationException

Throws:

java.io.IOException

InitializationException

testNullAndArrayElementsWithWarnStrategy

public void testNullAndArrayElementsWithWarnStrategy()
                                              throws InitializationException

Throws:

InitializationException

testNullAndArrayElementsWithIgnoreStrategy

public void testNullAndArrayElementsWithIgnoreStrategy()
                                                throws InitializationException

Throws:

InitializationException

testNullAndArrayElementsWithFailureStrategy

public void testNullAndArrayElementsWithFailureStrategy()
                                                 throws InitializationException

Throws:

InitializationException

testNullAndArrayElementsWithTextStrategy

public void testNullAndArrayElementsWithTextStrategy()
                                              throws InitializationException

Throws:

InitializationException

testNestedDocWithTextStrategy

public void testNestedDocWithTextStrategy()
                                   throws InitializationException

Throws:

InitializationException

testAllElementsAreNullOrArrays

public void testAllElementsAreNullOrArrays()
                                    throws InitializationException

Throws:

InitializationException

testInvalidJson

public void testInvalidJson()
                     throws InitializationException

Throws:

InitializationException

testTimestamp

public void testTimestamp()
                   throws java.io.UnsupportedEncodingException,
                          InitializationException

Throws:

java.io.UnsupportedEncodingException

InitializationException

testTimestampWithEL

public void testTimestampWithEL()
                         throws java.io.UnsupportedEncodingException,
                                InitializationException

Throws:

java.io.UnsupportedEncodingException

InitializationException