private boolean validateField()

in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/milvus/MilvusSink.java [357:381]

• 25 lines of code
• 10 McCabe index (conditional complexity)

  private boolean validateField(final String name, final String uri,
                                final CreateCollectionReq.CollectionSchema collectionSchema) {
    if (name.equals(this.vector)){
      return validateField(collectionSchema, name, this.vectorDataType);
    } else {
      if (uri.equals(BYTE)){
        return validateField(collectionSchema, name, DataType.Int8);
      } else if (uri.equals(SHORT)){
        return validateField(collectionSchema, name, DataType.Int16);
      } else if (uri.equals(INT)){
        return validateField(collectionSchema, name, DataType.Int32);
      } else if (uri.equals(LONG)){
        return validateField(collectionSchema, name, DataType.Int64);
      } else if (uri.equals(DOUBLE)){
        return validateField(collectionSchema, name, DataType.Double);
      } else if (uri.equals(FLOAT)){
        return validateField(collectionSchema, name, DataType.Float);
      } else if (uri.equals(BOOLEAN)){
        return validateField(collectionSchema, name, DataType.Bool);
      } else if (uri.equals(STRING)){
        return validateField(collectionSchema, name, DataType.VarChar);
      }
      return false;
    }
  }