Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 07:25:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Test flattenSpecs where the referred-to object is missing. (#5318)

Browse Source 
It worked, but it's still good to have a test.
This commit is contained in:
Gian Merlino 2018-02-27 15:10:30 -08:00 committed by GitHub
parent 0f009a41e1
commit 27bf619d5d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 27 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
api/src/test/java/io/druid/data/input/impl/InputRowParserSerdeTest.java
View File

@ -92,7 +92,11 @@ public class InputRowParserSerdeTest
final MapInputRowParser parser = new MapInputRowParser(
new JSONParseSpec(
new TimestampSpec("timeposix", "posix", null),
new DimensionsSpec(DimensionsSpec.getDefaultSchemas(ImmutableList.of("foo", "bar")), ImmutableList.of("baz"), null),
new DimensionsSpec(
DimensionsSpec.getDefaultSchemas(ImmutableList.of("foo", "bar")),
ImmutableList.of("baz"),
null
),
null,
null
)
@ -121,7 +125,11 @@ public class InputRowParserSerdeTest
final MapInputRowParser parser = new MapInputRowParser(
new JSONParseSpec(
new TimestampSpec("timemillis", "millis", null),
new DimensionsSpec(DimensionsSpec.getDefaultSchemas(ImmutableList.of("foo", "values")), ImmutableList.of("toobig", "value"), null),
new DimensionsSpec(
DimensionsSpec.getDefaultSchemas(ImmutableList.of("foo", "values")),
ImmutableList.of("toobig", "value"),
null
),
null,
null
)
@ -190,6 +198,7 @@ public class InputRowParserSerdeTest
fields.add(JSONPathFieldSpec.createNestedField("baz2", "$.baz[2]"));
fields.add(JSONPathFieldSpec.createNestedField("hey0barx", "$.hey[0].barx"));
fields.add(JSONPathFieldSpec.createNestedField("metA", "$.met.a"));
fields.add(JSONPathFieldSpec.createNestedField("missing", "$.nonexistent.nested.field"));
fields.add(JSONPathFieldSpec.createRootField("timestamp"));
fields.add(JSONPathFieldSpec.createRootField("foo.bar1"));
@ -212,7 +221,21 @@ public class InputRowParserSerdeTest
final InputRow parsed = parser2.parse(
"{\"blah\":[4,5,6], \"newmet\":5, \"foo\":{\"bar1\":\"aaa\", \"bar2\":\"bbb\"}, \"baz\":[1,2,3], \"timestamp\":\"2999\", \"foo.bar1\":\"Hello world!\", \"hey\":[{\"barx\":\"asdf\"}], \"met\":{\"a\":456}}"
);
Assert.assertEquals(ImmutableList.of("foobar1", "foobar2", "baz0", "baz1", "baz2", "hey0barx", "metA", "timestamp", "foo.bar1", "blah", "newmet", "baz"), parsed.getDimensions());
Assert.assertEquals(ImmutableList.of(
"foobar1",
"foobar2",
"baz0",
"baz1",
"baz2",
"hey0barx",
"metA",
"missing",
"timestamp",
"foo.bar1",
"blah",
"newmet",
"baz"
), parsed.getDimensions());
Assert.assertEquals(ImmutableList.of("aaa"), parsed.getDimension("foobar1"));
Assert.assertEquals(ImmutableList.of("bbb"), parsed.getDimension("foobar2"));
Assert.assertEquals(ImmutableList.of("1"), parsed.getDimension("baz0"));
@ -222,6 +245,7 @@ public class InputRowParserSerdeTest
Assert.assertEquals(ImmutableList.of("asdf"), parsed.getDimension("hey0barx"));
Assert.assertEquals(ImmutableList.of("456"), parsed.getDimension("metA"));
Assert.assertEquals(ImmutableList.of("5"), parsed.getDimension("newmet"));
Assert.assertEquals(ImmutableList.of(), parsed.getDimension("missing"));
Assert.assertEquals(DateTimes.of("2999").getMillis(), parsed.getTimestampFromEpoch());
String testSpec = "{\"enabled\": true,\"useFieldDiscovery\": true, \"fields\": [\"parseThisRootField\"]}";