Skip to content

Instantly share code, notes, and snippets.

@chriskearney
Created September 23, 2016 16:57
Show Gist options
  • Save chriskearney/ae1cd6ee43eb1132751b50ddfd8a6769 to your computer and use it in GitHub Desktop.
Save chriskearney/ae1cd6ee43eb1132751b50ddfd8a6769 to your computer and use it in GitHub Desktop.
List<Object> external_id = inputFileJsonLines.stream().map(new Function<String, Optional<JsonNode>>() {
public Optional<JsonNode> apply(String s) {
try {
return Optional.ofNullable(objectMapper.readTree(s));
} catch (IOException e) {
return Optional.empty();
}
}
}).filter(new Predicate<Optional<JsonNode>>() {
public boolean test(Optional<JsonNode> jsonNode) {
return jsonNode.isPresent();
}
}).filter(new Predicate<Optional<JsonNode>>() {
public boolean test(Optional<JsonNode> jsonNode) {
JsonNode node = jsonNode.get();
return node.has("external_id");
}
}).map(new Function<Optional<JsonNode>, JsonNode>() {
public JsonNode apply(Optional<JsonNode> jsonNode) {
return jsonNode.get();
}
}).collect(Collectors.toList());
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment