You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by sa...@apache.org on 2016/05/18 05:09:59 UTC
[2/3] incubator-apex-malhar git commit: updated unit tests
updated unit tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/10a7257b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/10a7257b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/10a7257b
Branch: refs/heads/master
Commit: 10a7257b7bdf7b2ae45bc69d9103bc23b3815e4d
Parents: 9ab4a4a
Author: shubham <sh...@github.com>
Authored: Fri May 13 12:22:46 2016 +0530
Committer: shubham <sh...@github.com>
Committed: Tue May 17 14:44:58 2016 +0530
----------------------------------------------------------------------
.../contrib/parser/CsvPOJOParserTest.java | 45 +++++++++++++++++---
1 file changed, 39 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/10a7257b/contrib/src/test/java/com/datatorrent/contrib/parser/CsvPOJOParserTest.java
----------------------------------------------------------------------
diff --git a/contrib/src/test/java/com/datatorrent/contrib/parser/CsvPOJOParserTest.java b/contrib/src/test/java/com/datatorrent/contrib/parser/CsvPOJOParserTest.java
index 4e2ae5d..b0e6322 100644
--- a/contrib/src/test/java/com/datatorrent/contrib/parser/CsvPOJOParserTest.java
+++ b/contrib/src/test/java/com/datatorrent/contrib/parser/CsvPOJOParserTest.java
@@ -28,6 +28,7 @@ import org.junit.runner.Description;
import com.datatorrent.lib.appdata.schemas.SchemaUtils;
import com.datatorrent.lib.testbench.CollectorTestSink;
+import com.datatorrent.lib.util.KeyValPair;
public class CsvPOJOParserTest
{
@@ -133,6 +134,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -160,6 +163,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -172,6 +177,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -184,6 +191,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -196,6 +205,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -208,6 +219,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -220,6 +233,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -232,6 +247,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -257,6 +274,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -269,6 +288,8 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
@@ -292,55 +313,67 @@ public class CsvPOJOParserTest
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
public void TestParserLessFields()
{
+ String input = "1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION";
parser.beginWindow(0);
- parser.in.process("1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION".getBytes());
+ parser.in.process(input.getBytes());
parser.endWindow();
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String,String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
public void TestParserLessFieldsOnlyPOJOPortConnected()
{
+ String input = "1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION";
parser.parsedOutput.setSink(null);
parser.beginWindow(0);
- parser.in.process("1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION".getBytes());
+ parser.in.process(input.getBytes());
parser.endWindow();
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String, String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
public void TestParserMoreFields()
{
+ String input = "1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION,CAMP_AD,Y,yes,ExtraField";
parser.beginWindow(0);
- parser.in.process("1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION,CAMP_AD,Y,yes,ExtraField"
- .getBytes());
+ parser.in.process(input.getBytes());
parser.endWindow();
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String, String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test
public void TestParserMoreFieldsOnlyPOJOPortConnected()
{
+ String input = "1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION,CAMP_AD,Y,yes,ExtraField";
parser.parsedOutput.setSink(null);
parser.beginWindow(0);
- parser.in.process(
- "1234,98233,adxyz,0.2,2015-03-08 03:37:12,11/12/2012,12,y,OPTIMIZATION,CAMP_AD,Y,yes,ExtraField".getBytes());
+ parser.in.process(input.getBytes());
parser.endWindow();
Assert.assertEquals(0, objectPort.collectedTuples.size());
Assert.assertEquals(0, pojoPort.collectedTuples.size());
Assert.assertEquals(1, error.collectedTuples.size());
+ KeyValPair<String, String> errorTuple = (KeyValPair<String, String>)error.collectedTuples.get(0);
+ Assert.assertEquals(input, errorTuple.getKey());
}
@Test