org.cripac.isee.vpe.data

Class DataManagingAppTest

java.lang.Object

org.cripac.isee.vpe.data.DataManagingAppTest

public class DataManagingAppTest
extends Object

This is a JUnit test for the DataManagingApp. Different from usual JUnit tests, this test does not initiate a DataManagingApp. The application should be run on YARN in advance. This test only sends fake data messages to and receives results from the already running application through Kafka.

Created by ken.yu on 16-10-31.

Field Summary

Fields

Modifier and Type	Field and Description
private ConsoleLogger	logger
private org.apache.kafka.clients.producer.KafkaProducer<String,byte[]>	producer

Constructor Summary

Constructors

Constructor and Description
DataManagingAppTest()

Method Summary

Modifier and Type	Method and Description
void	init()
void	init(String[] args)
static void	main(String[] args)
void	testAttrSaving()
void	testTrackletSaving()

Methods inherited from class java.lang.Object

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

Field Detail

producer

private org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer

logger

private ConsoleLogger logger

Constructor Detail

DataManagingAppTest

public DataManagingAppTest()

Method Detail

main

public static void main(String[] args)

init

public void init()
          throws Exception

Throws:

Exception

init

public void init(String[] args)
          throws Exception

Throws:

Exception

testTrackletSaving

public void testTrackletSaving()
                        throws Exception

Throws:

Exception

testAttrSaving

public void testAttrSaving()
                    throws Exception

Throws:

Exception