public void put()

in src/main/java/com/spotify/sparkey/CompressedWriter.java [45:63]

• 14 lines of code
• 3 McCabe index (conditional complexity)

  public void put(byte[] key, int keyLen, byte[] value, int valueLen) throws IOException {
    int keySize = Util.unsignedVLQSize(keyLen + 1) + Util.unsignedVLQSize(valueLen);
    int totalSize = keySize + keyLen + valueLen;

    smartFlush(keySize, totalSize);
    flushed = false;
    currentNumEntries++;

    Util.writeUnsignedVLQ(keyLen + 1, compressedOutputStream);
    Util.writeUnsignedVLQ(valueLen, compressedOutputStream);
    compressedOutputStream.write(key, 0, keyLen);
    compressedOutputStream.write(value, 0, valueLen);


    // Make sure that the beginning of each block is the start of a key/value pair
    if (flushed && compressedOutputStream.getPending() > 0) {
      compressedOutputStream.flush();
    }
  }