com.fasterxml.jackson.databind.node.ArrayNode.spliterator()方法的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(3.9k)|赞(0)|评价(0)|浏览(121)

本文整理了Java中com.fasterxml.jackson.databind.node.ArrayNode.spliterator()方法的一些代码示例,展示了ArrayNode.spliterator()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ArrayNode.spliterator()方法的具体详情如下:
包路径:com.fasterxml.jackson.databind.node.ArrayNode
类名称:ArrayNode
方法名:spliterator

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)

相关文章