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

Merge pull request #1945 from dclim/hadoop-spatial-dim 

fix spatial dimension transformer to work with hadoop
This commit is contained in:
Gian Merlino 2015-11-10 20:01:20 -08:00
parent e75c2a407d fd0935ecb9
commit 07157f9e9d
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
processing/src/main/java/io/druid/segment/incremental/SpatialDimensionRowTransformer.java
View File

@ -26,7 +26,6 @@ import com.google.common.collect.Iterables;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
import com.google.common.primitives.Floats;
import com.metamx.common.ISE;
import com.metamx.common.parsers.ParseException;
import io.druid.data.input.InputRow;
@ -201,7 +200,7 @@ public class SpatialDimensionRowTransformer implements Function<InputRow, InputR
return false;
}
for (String dimVal : dimVals) {
if (Floats.tryParse(dimVal) == null) {
if (tryParseFloat(dimVal) == null) {
return false;
}
}
@ -215,10 +214,18 @@ public class SpatialDimensionRowTransformer implements Function<InputRow, InputR
}
Iterable<String> dimVals = SPLITTER.split(dimVal);
for (String val : dimVals) {
if (Floats.tryParse(val) == null) {
if (tryParseFloat(val) == null) {
return false;
}
}
return true;
}
private static Float tryParseFloat(String val) {
try {
return Float.parseFloat(val);
} catch (NullPointerException | NumberFormatException e) {
return null;
}
}
}