本文整理了Java中com.fasterxml.jackson.databind.node.ArrayNode.spliterator()
方法的一些代码示例,展示了ArrayNode.spliterator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ArrayNode.spliterator()
方法的具体详情如下:
包路径:com.fasterxml.jackson.databind.node.ArrayNode
类名称:ArrayNode
方法名:spliterator
暂无
代码示例来源:origin: com.atlassian.addon.connect.hercules/hercules-ac
public static List<Comment> toComments(JsonNode commentResponseJson)
{
final ArrayNode commentsJSON = (ArrayNode) commentResponseJson.get("comments");
return StreamSupport.stream(commentsJSON.spliterator(), false).map(JsonCommentFactory::toComment).collect(Collectors.toList());
}
代码示例来源:origin: de.digitalcollections.iiif/iiif-apis
@Override
public Object handleUnexpectedToken(DeserializationContext ctxt, Class<?> targetType, JsonToken t, JsonParser p,
String failureMsg) throws IOException {
if (p.getCurrentName().equals("@type") && t == JsonToken.START_ARRAY) {
// Handle multi-valued @types, only current known cases are oa:SvgSelector and oa:CssStyle
// in combination with cnt:ContentAsText
ObjectMapper mapper = (ObjectMapper) p.getCodec();
String typeName = StreamSupport.stream(((ArrayNode) mapper.readTree(p)).spliterator(), false)
.map(JsonNode::textValue)
.filter(v -> !v.equals(ContentAsText.TYPE))
.findFirst().orElse(null);
if (typeName != null) {
return typeName;
}
}
return super.handleUnexpectedToken(ctxt, targetType, t, p, failureMsg);
}
代码示例来源:origin: jenkinsci/pipeline-aws-plugin
public static Collection<Tag> parseTags(InputStream is) throws IOException {
ObjectMapper mapper = new ObjectMapper();
JsonNode tree = mapper.readTree(is);
ArrayNode jsonNodes = (ArrayNode) tree;
return StreamSupport.stream(jsonNodes.spliterator(), false)
.map(node -> {
return new Tag()
.withKey(node.get("Key").asText())
.withValue(node.get("Value").asText());
})
.collect(Collectors.toList());
}
}
代码示例来源:origin: org.rakam/rakam-aws-kinesis
private void updateNode() {
try {
ArrayNode result;
try {
URLConnection yc = coordinatorAddress.openConnection();
byte[] json = ByteStreams.toByteArray(yc.getInputStream());
result = JsonHelper.read(json, ArrayNode.class);
} catch (ConnectException e) {
LOGGER.warn(String.format("Couldn't connect Presto coordinator %s: %s",
coordinatorAddress.toString(), e.getMessage()));
return;
}catch (IOException e) {
e.printStackTrace();
return;
}
Set<String> activeNodes = StreamSupport.stream(result.spliterator(), false)
.map(node -> URI.create(node.get("uri").asText()).getHost()).collect(Collectors.toSet());
activeNodes.add(coordinatorAddress.getHost());
Set<String> removedNodes = nodes.stream().filter(node -> !activeNodes.contains(node)).collect(Collectors.toSet());
Set<String> newNodes = activeNodes.stream().filter(node -> !nodes.contains(node)).collect(Collectors.toSet());
newNodes.forEach(node -> membership.addMember(new Member(node, config.getPort())));
removedNodes.forEach(node -> membership.removeMember(new Member(node, config.getPort())));
nodes = newNodes;
} catch (Exception e) {
e.printStackTrace();
}
}
}
代码示例来源:origin: spotify/styx
return StreamSupport.stream(events.spliterator(), false)
.map(eventWithTimestamp -> {
final long ts = eventWithTimestamp.get("timestamp").asLong();
代码示例来源:origin: io.syndesis.server/server-api-generator
StreamSupport.stream(parameters.spliterator(), false).collect(Collectors.toList()));
代码示例来源:origin: de.digitalcollections.iiif/iiif-apis
} else if (valueNode instanceof ArrayNode) {
StreamSupport.stream(((ArrayNode) valueNode).spliterator(), false)
.map(JsonNode::textValue)
.forEach(v -> propVal.addValue(locale, v));
代码示例来源:origin: io.syndesis.server/server-connector-generator
StreamSupport.stream(parameters.spliterator(), false).collect(Collectors.toList()));
代码示例来源:origin: de.digitalcollections.iiif/iiif-apis
obj.withArray("qualities").spliterator(), false)
.map(q -> q.asText().equals("native") ? "default" : q.asText())
.map(q -> q.equals("grey") ? "gray" : q)
内容来源于网络,如有侵权,请联系作者删除!