public void addTuple()

in tajo-storage/src/main/java/org/apache/tajo/storage/trevni/TrevniAppender.java [127:176]

46 lines of code
19 McCabe index (conditional complexity)


  public void addTuple(Tuple t) throws IOException {
    Column col;
    writer.startRow();
    for (int i = 0; i < schema.size(); i++) {
      if (enabledStats) {
        stats.analyzeField(i, t.get(i));
      }

      if (!t.isNull(i)) {
        col = schema.getColumn(i);
        switch (col.getDataType().getType()) {
          case NULL_TYPE:
            break;
          case BOOLEAN:
          case BIT:
          case INT2:
          case INT4:
            writer.writeValue(t.get(i).asInt4(), i);
            break;
          case INT8:
            writer.writeValue(t.get(i).asInt8(), i);
            break;
          case FLOAT4:
            writer.writeValue(t.get(i).asFloat4(), i);
            break;
          case FLOAT8:
            writer.writeValue(t.get(i).asFloat8(), i);
            break;
          case CHAR:
          case TEXT:
            writer.writeValue(t.get(i).asChars(), i);
            break;
          case PROTOBUF:
          case BLOB:
          case INET4:
          case INET6:
            writer.writeValue(t.get(i).asByteArray(), i);

          default:
            break;
        }
      }
    }
    writer.endRow();

    // Statistical section
    if (enabledStats) {
      stats.incrementRow();
    }
  }