public Status insert()

in core/src/main/java/site/ycsb/BasicTSDB.java [174:224]
47 lines of code
11 McCabe index (conditional complexity)

  public Status insert(String table, String key, Map<String, ByteIterator> values) {
    delay();
    
    boolean isFloat = false;
    
    if (verbose) {
      StringBuilder sb = getStringBuilder();
      sb.append("INSERT ").append(table).append(" ").append(key).append(" [ ");
      if (values != null) {
        final TreeMap<String, ByteIterator> tree = new TreeMap<String, ByteIterator>(values);
        for (Map.Entry<String, ByteIterator> entry : tree.entrySet()) {
          if (entry.getKey().equals(timestampKey)) {
            sb.append(entry.getKey()).append("=")
              .append(Utils.bytesToLong(entry.getValue().toArray())).append(" ");
          } else if (entry.getKey().equals(valueKey)) {
            final NumericByteIterator it = (NumericByteIterator) entry.getValue();
            isFloat = it.isFloatingPoint();
            sb.append(entry.getKey()).append("=")
              .append(isFloat ? it.getDouble() : it.getLong()).append(" ");
          } else {
            sb.append(entry.getKey()).append("=").append(entry.getValue()).append(" ");
          }
        }
      }
      sb.append("]");
      System.out.println(sb);
    }

    if (count) {
      if (!verbose) {
        isFloat = ((NumericByteIterator) values.get(valueKey)).isFloatingPoint();
      }
      int hash = hash(table, key, values);
      incCounter(inserts, hash);
      synchronized(timestamps) {
        Integer ctr = timestamps.get(lastTimestamp);
        if (ctr == null) {
          timestamps.put(lastTimestamp, 1);
        } else {
          timestamps.put(lastTimestamp, ctr + 1);
        }
      }
      if (isFloat) {
        incCounter(floats, hash);
      } else {
        incCounter(integers, hash);
      }
    }

    return Status.OK;
  }