From 34bd7c546b52887606082b285c1d90d46b9ed418 Mon Sep 17 00:00:00 2001 From: shaofengshi Date: Sun, 4 Jan 2015 14:51:18 +0800 Subject: [PATCH] Update test case BaseCuboidMapperTest --- .../java/com/kylinolap/job/hadoop/cube/BaseCuboidMapperTest.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/job/src/test/java/com/kylinolap/job/hadoop/cube/BaseCuboidMapperTest.java b/job/src/test/java/com/kylinolap/job/hadoop/cube/BaseCuboidMapperTest.java index 495ee0f..78598f7 100644 --- a/job/src/test/java/com/kylinolap/job/hadoop/cube/BaseCuboidMapperTest.java +++ b/job/src/test/java/com/kylinolap/job/hadoop/cube/BaseCuboidMapperTest.java @@ -74,7 +74,7 @@ public void testMapperWithHeader() throws Exception { mapDriver.getConfiguration().set(BatchConstants.CFG_CUBE_SEGMENT_NAME, segmentName); // mapDriver.getConfiguration().set(BatchConstants.CFG_METADATA_URL, // metadata); - mapDriver.withInput(new Text("key"), new Text("2012-12-15118480Health & BeautyFragrancesWomenAuction15123456789132.331")); + mapDriver.withInput(new Text("key"), new Text("2012-12-15118480Health & BeautyFragrancesWomenAuction15123456789132.33")); List> result = mapDriver.run(); CubeManager cubeMgr = CubeManager.getInstance(this.getTestConfig()); @@ -96,17 +96,16 @@ public void testMapperWithHeader() throws Exception { assertEquals(511, Bytes.toLong(cuboidId)); assertEquals(22, restKey.length); - verifyMeasures(cube.getDescriptor().getMeasures(), result.get(0).getSecond(), "132.33", "132.33", "132.33", 1); + verifyMeasures(cube.getDescriptor().getMeasures(), result.get(0).getSecond(), "132.33", "132.33", "132.33"); } - private void verifyMeasures(List measures, Text valueBytes, String m1, String m2, String m3, long m4) { + private void verifyMeasures(List measures, Text valueBytes, String m1, String m2, String m3) { MeasureCodec codec = new MeasureCodec(measures); Object[] values = new Object[measures.size()]; codec.decode(valueBytes, values); assertTrue(new BigDecimal(m1).equals(values[0])); assertTrue(new BigDecimal(m2).equals(values[1])); assertTrue(new BigDecimal(m3).equals(values[2])); - assertTrue(m4 == ((LongWritable) values[3]).get()); } @Test @@ -139,6 +138,6 @@ public void testMapperWithNull() throws Exception { assertEquals(511, Bytes.toLong(cuboidId)); assertEquals(22, restKey.length); - verifyMeasures(cube.getDescriptor().getMeasures(), result.get(0).getSecond(), "0", "0", "0", 1L); + verifyMeasures(cube.getDescriptor().getMeasures(), result.get(0).getSecond(), "0", "0", "0"); } }