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

ArrayNode.size介绍

暂无

代码示例

代码示例来源：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

@Test
public void getNumberOfTaskManagers() {
  try {
    String json = TestBaseUtils.getFromHTTP("http://localhost:" + getRestPort() + "/taskmanagers/");
    ObjectMapper mapper = new ObjectMapper();
    JsonNode response = mapper.readTree(json);
    ArrayNode taskManagers = (ArrayNode) response.get("taskmanagers");
    assertNotNull(taskManagers);
    assertEquals(NUM_TASK_MANAGERS, taskManagers.size());
  } catch (Exception e) {
    e.printStackTrace();
    fail(e.getMessage());
  }
}

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

@Test
public void getTaskmanagers() throws Exception {
  String json = TestBaseUtils.getFromHTTP("http://localhost:" + getRestPort() + "/taskmanagers/");
  ObjectMapper mapper = new ObjectMapper();
  JsonNode parsed = mapper.readTree(json);
  ArrayNode taskManagers = (ArrayNode) parsed.get("taskmanagers");
  assertNotNull(taskManagers);
  assertEquals(NUM_TASK_MANAGERS, taskManagers.size());
  JsonNode taskManager = taskManagers.get(0);
  assertNotNull(taskManager);
  assertEquals(NUM_SLOTS, taskManager.get("slotsNumber").asInt());
  assertTrue(taskManager.get("freeSlots").asInt() <= NUM_SLOTS);
}

代码示例来源：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

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");
}