public void configure()

in flume-hbase2-sink/src/main/java/org/apache/flume/sink/hbase2/SimpleHBase2EventSerializer.java [63:91]

• 28 lines of code
• 8 McCabe index (conditional complexity)

  public void configure(Context context) {
    rowPrefix = context.getString("rowPrefix", "default");
    incrementRow =
        context.getString("incrementRow", "incRow").getBytes(Charsets.UTF_8);
    String suffix = context.getString("suffix", "uuid");

    String payloadColumn = context.getString("payloadColumn", "pCol");
    String incColumn = context.getString("incrementColumn", "iCol");
    if (payloadColumn != null && !payloadColumn.isEmpty()) {
      switch (suffix) {
        case "timestamp":
          keyType = KeyType.TS;
          break;
        case "random":
          keyType = KeyType.RANDOM;
          break;
        case "nano":
          keyType = KeyType.TSNANO;
          break;
        default:
          keyType = KeyType.UUID;
          break;
      }
      plCol = payloadColumn.getBytes(Charsets.UTF_8);
    }
    if (incColumn != null && !incColumn.isEmpty()) {
      incCol = incColumn.getBytes(Charsets.UTF_8);
    }
  }