private void initField()

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

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

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