| /** |
| * Put your copyright and license info here. |
| */ |
| package com.example.dedup; |
| |
| import java.io.IOException; |
| |
| import javax.validation.ConstraintViolationException; |
| |
| import org.junit.Assert; |
| |
| import org.apache.hadoop.conf.Configuration; |
| import org.junit.Test; |
| |
| import com.datatorrent.api.LocalMode; |
| import com.example.dedup.Application; |
| |
| /** |
| * Test the DAG declaration in local mode. |
| */ |
| public class ApplicationTest { |
| |
| @Test |
| public void testApplication() throws IOException, Exception { |
| try { |
| LocalMode lma = LocalMode.newInstance(); |
| Configuration conf = new Configuration(false); |
| conf.addResource(this.getClass().getResourceAsStream("/META-INF/properties.xml")); |
| lma.prepareDAG(new Application(), conf); |
| LocalMode.Controller lc = lma.getController(); |
| lc.runAsync(); |
| Thread.sleep(10 * 1000); |
| lc.shutdown(); |
| } catch (ConstraintViolationException e) { |
| Assert.fail("constraint violations: " + e.getConstraintViolations()); |
| } |
| } |
| } |