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

KeyMap.size介绍

[英]Gets the number of elements currently in the map.
[中]获取映射中当前的元素数。

代码示例

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

@Override
  public int compare(KeyMap<?, ?> o1, KeyMap<?, ?> o2) {
    // this sorts descending
    int cmp = o2.getLog2TableCapacity() - o1.getLog2TableCapacity();
    if (cmp != 0) {
      return cmp;
    }
    else {
      return o2.size() - o1.size();
    }
  }
}

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

map.putIfAbsent(i, factory);
  assertEquals(i + 1, map.size());
  assertTrue(map.getCurrentTableCapacity() > map.size());
  assertTrue(map.getCurrentTableCapacity() > map.getRehashThreshold());
  assertTrue(map.size() <= map.getRehashThreshold());
assertEquals(numElements, map.size());
assertEquals(numElements, map.traverseAndCountElements());
assertEquals(1 << 21, map.getCurrentTableCapacity());
assertEquals(numElements, map.size());
assertEquals(numElements, map.traverseAndCountElements());
assertEquals(1 << 21, map.getCurrentTableCapacity());

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

numContained += map.size();

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

map.put(i, 2 * i + 1);
  assertEquals(i + 1, map.size());
  assertTrue(map.getCurrentTableCapacity() > map.size());
  assertTrue(map.getCurrentTableCapacity() > map.getRehashThreshold());
  assertTrue(map.size() <= map.getRehashThreshold());
assertEquals(numElements, map.size());
assertEquals(numElements, map.traverseAndCountElements());
assertEquals(1 << 21, map.getCurrentTableCapacity());
assertEquals(numElements, bitset.cardinality());
assertEquals(numElements, map.size());
assertEquals(numElements, map.traverseAndCountElements());
assertEquals(1 << 21, map.getCurrentTableCapacity());

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

assertEquals(numElements, map.size());
assertEquals(numElements, map.traverseAndCountElements());
assertEquals(1 << 21, map.getCurrentTableCapacity());

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

@Test
public void testPutIfAbsentDuplicateKeysAndGrowth() {
  try {
    KeyMap<Integer, Integer> map = new KeyMap<>();
    IntegerFactory factory = new IntegerFactory();
    final int numElements = 1000000;
    for (int i = 0; i < numElements; i++) {
      int val = 2 * i + 1;
      factory.set(val);
      Integer put = map.putIfAbsent(i, factory);
      assertEquals(val, put.intValue());
    }
    for (int i = 0; i < numElements; i += 3) {
      factory.set(2 * i);
      Integer put = map.putIfAbsent(i, factory);
      assertEquals(2 * i + 1, put.intValue());
    }
    for (int i = 0; i < numElements; i++) {
      assertEquals(2 * i + 1, map.get(i).intValue());
    }
    assertEquals(numElements, map.size());
    assertEquals(numElements, map.traverseAndCountElements());
    assertEquals(1 << 21, map.getCurrentTableCapacity());
    assertTrue(map.getLongestChainLength() <= 7);
  }
  catch (Exception e) {
    e.printStackTrace();
    fail(e.getMessage());
  }
}

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

@Override
  public int compare(KeyMap<?, ?> o1, KeyMap<?, ?> o2) {
    // this sorts descending
    int cmp = o2.getLog2TableCapacity() - o1.getLog2TableCapacity();
    if (cmp != 0) {
      return cmp;
    }
    else {
      return o2.size() - o1.size();
    }
  }
}

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

@Override
  public int compare(KeyMap<?, ?> o1, KeyMap<?, ?> o2) {
    // this sorts descending
    int cmp = o2.getLog2TableCapacity() - o1.getLog2TableCapacity();
    if (cmp != 0) {
      return cmp;
    }
    else {
      return o2.size() - o1.size();
    }
  }
}

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

@Override
  public int compare(KeyMap<?, ?> o1, KeyMap<?, ?> o2) {
    // this sorts descending
    int cmp = o2.getLog2TableCapacity() - o1.getLog2TableCapacity();
    if (cmp != 0) {
      return cmp;
    }
    else {
      return o2.size() - o1.size();
    }
  }
}

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

public void writeToOutput(
    final DataOutputView output,
    final TypeSerializer<Key> keySerializer,
    final TypeSerializer<Aggregate> aggSerializer) throws IOException {
  output.writeInt(BEGIN_OF_STATE_MAGIC_NUMBER);
  int numPanes = getNumPanes();
  output.writeInt(numPanes);
  // write from the past
  Iterator<KeyMap<Key, Aggregate>> previous = previousPanes.iterator();
  for (int paneNum = 0; paneNum < numPanes; paneNum++) {
    output.writeInt(BEGIN_OF_PANE_MAGIC_NUMBER);
    KeyMap<Key, Aggregate> pane = (paneNum == numPanes - 1) ? latestPane : previous.next();
    output.writeInt(pane.size());
    for (KeyMap.Entry<Key, Aggregate> entry : pane) {
      keySerializer.serialize(entry.getKey(), output);
      aggSerializer.serialize(entry.getValue(), output);
    }
  }
}