public void accept()

in modules/accumulo/src/main/java/org/apache/fluo/accumulo/summarizer/FluoCollector.java [40:81]

40 lines of code
11 McCabe index (conditional complexity)


  public void accept(Key k, Value v) {

    if (NotificationUtil.isNtfy(k)) {
      if (NotificationUtil.isDelete(k)) {
        ntfyDel++;
      } else {
        ntfy++;
      }

    } else {
      ColumnType colType = ColumnType.from(k);
      switch (colType) {
        case TX_DONE:
          txDone++;
          break;
        case DEL_LOCK:
          delLock++;
          break;
        case LOCK:
          lock++;
          break;
        case DATA:
          data++;
          break;
        case WRITE:
          write++;
          break;
        case ACK:
          ack++;
          break;
        case RLOCK:
          if (ReadLockUtil.isDelete(k.getTimestamp())) {
            delrlock++;
          } else {
            rlock++;
          }
          break;
        default:
          throw new IllegalArgumentException("Unknown column type : " + colType);
      }
    }
  }