Merge pull request #780 from metamx/new-druid-api

update druid-api for json parsing improvements
This commit is contained in:
fjy 2014-10-07 14:35:39 -06:00
commit 5be4d6b4aa
5 changed files with 12 additions and 5 deletions

View File

@ -41,7 +41,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<metamx.java-util.version>0.26.8</metamx.java-util.version>
<apache.curator.version>2.6.0</apache.curator.version>
<druid.api.version>0.2.11</druid.api.version>
<druid.api.version>0.2.12</druid.api.version>
</properties>
<modules>

View File

@ -69,7 +69,8 @@ public class ProtoBufInputRowParser implements ByteBufferInputRowParser
if (parseSpec == null) {
this.parseSpec = new JSONParseSpec(
timestampSpec,
new DimensionsSpec(dimensions, dimensionExclusions, spatialDimensions)
new DimensionsSpec(dimensions, dimensionExclusions, spatialDimensions),
JSONParseSpec.JSON
);
} else {
this.parseSpec = parseSpec;

View File

@ -59,7 +59,8 @@ public class ProtoBufInputRowParserTest
ProtoBufInputRowParser parser = new ProtoBufInputRowParser(
new JSONParseSpec(
new TimestampSpec("timestamp", "iso"),
new DimensionsSpec(Arrays.asList(DIMENSIONS), Arrays.<String>asList(), null)
new DimensionsSpec(Arrays.asList(DIMENSIONS), Arrays.<String>asList(), null),
JSONParseSpec.JSON
),
"prototest.desc",
null, null, null, null

View File

@ -61,7 +61,8 @@ public class FireDepartmentTest
Arrays.asList("dim1", "dim2"),
null,
null
)
),
JSONParseSpec.JSON
),
null, null, null, null
),

View File

@ -123,7 +123,11 @@ public class RealtimePlumberSchoolTest
@Override
public ParseSpec getParseSpec()
{
return new JSONParseSpec(new TimestampSpec("timestamp", "auto"), new DimensionsSpec(null, null, null));
return new JSONParseSpec(
new TimestampSpec("timestamp", "auto"),
new DimensionsSpec(null, null, null),
JSONParseSpec.JSON
);
}
@Override