Method deserializeFromDDF

core/src/main/java/io/ddf/ml/Model.java:162–187

(BasicDDF ddf)

  }

  public static Model deserializeFromDDF(BasicDDF ddf) throws DDFException {
    List<String> data = ddf.getList(String.class);
    List<String> metaData = new ArrayList<String>();
    List<Schema.Column> columns = ddf.getSchema().getColumns();

    for (Schema.Column col : columns) {
      metaData.add(col.getName());
    }
    if (metaData.size() != data.size()) {
      throw new DDFException("");
    }

    List<String> listJson = new ArrayList<String>();

    for (int i = 0; i < metaData.size(); i++) {
      String key = metaData.get(i);
      String value = data.get(i);
      listJson.add(String.format("\"%s\":%s", key, value));
    }

    String json = StringUtils.join(listJson, ",");
    Model model = Model.fromJson(String.format("{%s}", json));

    ddf.getManager().addModel(model);
    return model;
  }

  static class ModelDeserializer implements JsonDeserializer<Model> {
    private Gson _gson = new Gson();