Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix type cast warnings

This commit is contained in:
Xavier Léauté 2015-09-21 09:55:44 -07:00
parent af86c0e6ea
commit 8f489c1f66
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/test/java/io/druid/segment/indexing/DataSchemaTest.java
View File

@ -17,6 +17,7 @@
package io.druid.segment.indexing; package io.druid.segment.indexing;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.InjectableValues; import com.fasterxml.jackson.databind.InjectableValues;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
@ -56,7 +57,7 @@ public class DataSchemaTest
new TimestampSpec("time", "auto", null), new TimestampSpec("time", "auto", null),
new DimensionsSpec(ImmutableList.of("dimB", "dimA"), null, null) new DimensionsSpec(ImmutableList.of("dimB", "dimA"), null, null)
) )
), Map.class ), new TypeReference<Map<String, Object>>() {}
); );
DataSchema schema = new DataSchema( DataSchema schema = new DataSchema(
@ -85,7 +86,7 @@ public class DataSchemaTest
new TimestampSpec("time", "auto", null), new TimestampSpec("time", "auto", null),
new DimensionsSpec(ImmutableList.of("time", "dimA", "dimB", "col2"), ImmutableList.of("dimC"), null) new DimensionsSpec(ImmutableList.of("time", "dimA", "dimB", "col2"), ImmutableList.of("dimC"), null)
) )
), Map.class ), new TypeReference<Map<String, Object>>() {}
); );
DataSchema schema = new DataSchema( DataSchema schema = new DataSchema(
@ -114,7 +115,7 @@ public class DataSchemaTest
new TimestampSpec("time", "auto", null), new TimestampSpec("time", "auto", null),
new DimensionsSpec(ImmutableList.of("time", "dimA", "dimB", "metric1"), ImmutableList.of("dimC"), null) new DimensionsSpec(ImmutableList.of("time", "dimA", "dimB", "metric1"), ImmutableList.of("dimC"), null)
) )
), Map.class ), new TypeReference<Map<String, Object>>() {}
); );
DataSchema schema = new DataSchema( DataSchema schema = new DataSchema(
@ -189,13 +190,13 @@ public class DataSchemaTest
Assert.assertEquals( Assert.assertEquals(
new DataSchema( new DataSchema(
"test", "test",
jsonMapper.convertValue( jsonMapper.<Map<String, Object>>convertValue(
new StringInputRowParser( new StringInputRowParser(
new JSONParseSpec( new JSONParseSpec(
new TimestampSpec("xXx", null, null), new TimestampSpec("xXx", null, null),
new DimensionsSpec(null, null, null) new DimensionsSpec(null, null, null)
) )
), Map.class ), new TypeReference<Map<String, Object>>() {}
), ),
new AggregatorFactory[]{ new AggregatorFactory[]{
new DoubleSumAggregatorFactory("metric1", "col1") new DoubleSumAggregatorFactory("metric1", "col1")