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

ArrayNode.add介绍

暂无

代码示例

代码示例来源：origin: apache/flink

private ArrayNode convertObjectArray(ArrayNode reuse, TypeInformation<?> info, Object[] array) {
    if (reuse == null) {
      reuse = mapper.createArrayNode();
    } else {
      reuse.removeAll();
    }

    for (Object object : array) {
      reuse.add(convert(reuse, null, info, object));
    }
    return reuse;
  }
}

代码示例来源：origin: apache/flink

private void visitIteration(ArrayNode jsonArray, List<Integer> toVisit, int headId,
    Map<Integer, Integer> edgeRemapings, ArrayNode iterationInEdges) {
  Integer vertexID = toVisit.get(0);
  StreamNode vertex = streamGraph.getStreamNode(vertexID);
  toVisit.remove(vertexID);
  // Ignoring head and tail to avoid redundancy
  if (!streamGraph.vertexIDtoLoopTimeout.containsKey(vertexID)) {
    ObjectNode obj = mapper.createObjectNode();
    jsonArray.add(obj);
    decorateNode(vertexID, obj);
    ArrayNode inEdges = mapper.createArrayNode();
    obj.put(PREDECESSORS, inEdges);
    for (StreamEdge inEdge : vertex.getInEdges()) {
      int inputID = inEdge.getSourceId();
      if (edgeRemapings.keySet().contains(inputID)) {
        decorateEdge(inEdges, inEdge, inputID);
      } else if (!streamGraph.vertexIDtoLoopTimeout.containsKey(inputID)) {
        decorateEdge(iterationInEdges, inEdge, inputID);
      }
    }
    edgeRemapings.put(vertexID, headId);
    visitIteration(jsonArray, toVisit, headId, edgeRemapings, iterationInEdges);
  }
}

代码示例来源：origin: apache/flink

private void decorateEdge(ArrayNode inputArray, StreamEdge inEdge, int mappedInputID) {
  ObjectNode input = mapper.createObjectNode();
  inputArray.add(input);
  input.put(ID, mappedInputID);
  input.put(SHIP_STRATEGY, inEdge.getPartitioner().toString());
  input.put(SIDE, (inputArray.size() == 0) ? "first" : "second");
}

代码示例来源：origin: apache/flink

jsonArray.add(node);
  toVisit.remove(vertexID);
} else {
  toVisit.remove(iterationHead);
  visitIteration(iterationSteps, toVisit, iterationHead, edgeRemapings, iterationInputs);
  jsonArray.add(obj);

代码示例来源：origin: com.alibaba.blink/flink-json

private ArrayNode convertObjectArray(ArrayNode reuse, TypeInformation<?> info, Object[] array) {
    if (reuse == null) {
      reuse = mapper.createArrayNode();
    } else {
      reuse.removeAll();
    }

    for (Object object : array) {
      reuse.add(convert(reuse, null, info, object));
    }
    return reuse;
  }
}

代码示例来源：origin: org.apache.flink/flink-json

private ArrayNode convertObjectArray(ArrayNode reuse, TypeInformation<?> info, Object[] array) {
    if (reuse == null) {
      reuse = mapper.createArrayNode();
    } else {
      reuse.removeAll();
    }

    for (Object object : array) {
      reuse.add(convert(reuse, null, info, object));
    }
    return reuse;
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java

private void visitIteration(ArrayNode jsonArray, List<Integer> toVisit, int headId,
    Map<Integer, Integer> edgeRemapings, ArrayNode iterationInEdges) {
  Integer vertexID = toVisit.get(0);
  StreamNode vertex = streamGraph.getStreamNode(vertexID);
  toVisit.remove(vertexID);
  // Ignoring head and tail to avoid redundancy
  if (!streamGraph.vertexIDtoLoopTimeout.containsKey(vertexID)) {
    ObjectNode obj = mapper.createObjectNode();
    jsonArray.add(obj);
    decorateNode(vertexID, obj);
    ArrayNode inEdges = mapper.createArrayNode();
    obj.put(PREDECESSORS, inEdges);
    for (StreamEdge inEdge : vertex.getInEdges()) {
      int inputID = inEdge.getSourceId();
      if (edgeRemapings.keySet().contains(inputID)) {
        decorateEdge(inEdges, inEdge, inputID);
      } else if (!streamGraph.vertexIDtoLoopTimeout.containsKey(inputID)) {
        decorateEdge(iterationInEdges, inEdge, inputID);
      }
    }
    edgeRemapings.put(vertexID, headId);
    visitIteration(jsonArray, toVisit, headId, edgeRemapings, iterationInEdges);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

private void decorateEdge(ArrayNode inputArray, StreamEdge inEdge, int mappedInputID) {
  ObjectNode input = mapper.createObjectNode();
  inputArray.add(input);
  input.put(ID, mappedInputID);
  input.put(SHIP_STRATEGY, inEdge.getPartitioner().toString());
  input.put(SIDE, (inputArray.size() == 0) ? "first" : "second");
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

private void visitIteration(ArrayNode jsonArray, List<Integer> toVisit, int headId,
    Map<Integer, Integer> edgeRemapings, ArrayNode iterationInEdges) {
  Integer vertexID = toVisit.get(0);
  StreamNode vertex = streamGraph.getStreamNode(vertexID);
  toVisit.remove(vertexID);
  // Ignoring head and tail to avoid redundancy
  if (!streamGraph.vertexIDtoLoopTimeout.containsKey(vertexID)) {
    ObjectNode obj = mapper.createObjectNode();
    jsonArray.add(obj);
    decorateNode(vertexID, obj);
    ArrayNode inEdges = mapper.createArrayNode();
    obj.put(PREDECESSORS, inEdges);
    for (StreamEdge inEdge : vertex.getInEdges()) {
      int inputID = inEdge.getSourceId();
      if (edgeRemapings.keySet().contains(inputID)) {
        decorateEdge(inEdges, inEdge, inputID);
      } else if (!streamGraph.vertexIDtoLoopTimeout.containsKey(inputID)) {
        decorateEdge(iterationInEdges, inEdge, inputID);
      }
    }
    edgeRemapings.put(vertexID, headId);
    visitIteration(jsonArray, toVisit, headId, edgeRemapings, iterationInEdges);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java

private void decorateEdge(ArrayNode inputArray, StreamEdge inEdge, int mappedInputID) {
  ObjectNode input = mapper.createObjectNode();
  inputArray.add(input);
  input.put(ID, mappedInputID);
  input.put(SHIP_STRATEGY, inEdge.getPartitioner().toString());
  input.put(SIDE, (inputArray.size() == 0) ? "first" : "second");
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

jsonArray.add(node);
  toVisit.remove(vertexID);
} else {
  toVisit.remove(iterationHead);
  visitIteration(iterationSteps, toVisit, iterationHead, edgeRemapings, iterationInputs);
  jsonArray.add(obj);

代码示例来源：origin: org.apache.flink/flink-streaming-java

jsonArray.add(node);
  toVisit.remove(vertexID);
} else {
  toVisit.remove(iterationHead);
  visitIteration(iterationSteps, toVisit, iterationHead, edgeRemapings, iterationInputs);
  jsonArray.add(obj);