private static Column parseColumn()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkTask.java [601:617]

• 12 lines of code
• 5 McCabe index (conditional complexity)

  private static Column parseColumn(JsonObject node) {
    String name = node.has("name") ? node.get("name").getAsString() : null;

    if (name == null) {
      throw new IllegalArgumentException("Invalid schema, column name cannot be null");
    }

    String typeString = node.has("type") ? node.get("type").getAsString().toUpperCase() : null;

    if (typeString == null) {
      throw new IllegalArgumentException("Invalid schema, column type cannot be null");
    }

    TypeInfo typeInfo = TypeInfoParser.getTypeInfoFromTypeString(typeString);

    return new Column(name, typeInfo, null, null, null);
  }