forked from antonis.lempesis/dnet-hadoop
do not fail on uknown properties when grouping entities by ID
This commit is contained in:
parent
3c10941376
commit
1eaad89a3c
|
@ -10,6 +10,7 @@ import java.util.Objects;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.databind.DeserializationFeature;
|
||||||
import org.apache.commons.io.IOUtils;
|
import org.apache.commons.io.IOUtils;
|
||||||
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.StringUtils;
|
||||||
import org.apache.spark.SparkConf;
|
import org.apache.spark.SparkConf;
|
||||||
|
@ -42,9 +43,8 @@ public class GroupEntitiesSparkJob {
|
||||||
|
|
||||||
private final static String ID_JPATH = "$.id";
|
private final static String ID_JPATH = "$.id";
|
||||||
|
|
||||||
private final static String SOURCE_JPATH = "$.source";
|
private static ObjectMapper OBJECT_MAPPER = new ObjectMapper()
|
||||||
|
.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
|
||||||
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
|
|
||||||
|
|
||||||
public static void main(String[] args) throws Exception {
|
public static void main(String[] args) throws Exception {
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue