org.apache.storm.kafka

Class StringKeyValueSchemeTest

java.lang.Object

org.apache.storm.kafka.StringKeyValueSchemeTest

public class StringKeyValueSchemeTest
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
StringKeyValueSchemeTest()

Method Summary

Modifier and Type	Method and Description
void	testDeserialize()
void	testDeserializeWithKeyAndValue()
void	testDeserializeWithNullKeyAndValue()
void	testGetOutputFields()

Methods inherited from class java.lang.Object

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

Constructor Detail

StringKeyValueSchemeTest

public StringKeyValueSchemeTest()

Method Detail

testDeserialize

public void testDeserialize()
                     throws java.lang.Exception

Throws:

java.lang.Exception

testGetOutputFields

public void testGetOutputFields()
                         throws java.lang.Exception

Throws:

java.lang.Exception

testDeserializeWithNullKeyAndValue

public void testDeserializeWithNullKeyAndValue()
                                        throws java.lang.Exception

Throws:

java.lang.Exception

testDeserializeWithKeyAndValue

public void testDeserializeWithKeyAndValue()
                                    throws java.lang.Exception

Throws:

java.lang.Exception