jsonschema2pojo-maven-plugin v0.4.7を使用して、JSON スキーマから POJO クラスを生成しています。サンプル スキーマは次のとおりです。
"features": {
"title": "Feature",
"description": "Name and type of every feature in the model",
"type": "array",
"items": {
"properties": {
"columnName": {
"description": "Name of the table column",
"type": "string"
},
"featureName": {
"description": "Name of that column's feature for the pipeline",
"type": "string"
},
"type": {
"description": "Type of the feature",
"type": "string"
}
},
"required": ["columnName", "type"]
}
結果の POJO クラスは次のようになります。
public class Feature {
/**
* Name of the table column
*
*/
@JsonProperty("columnName")
private String columnName;
/**
* Name of that column's feature for the pipeline
*
*/
@JsonProperty("featureName")
private String featureName;
/**
* Type of the feature
*
*/
@JsonProperty("type")
private String type;
@JsonIgnore
private Map<String, Object> additionalProperties = new HashMap<String, Object>();
/**
* Name of the table column
*
* @return
* The columnName
*/
@JsonProperty("columnName")
public String getColumnName() {
return columnName;
}
/**
* Name of the table column
*
* @param columnName
* The columnName
*/
@JsonProperty("columnName")
public void setColumnName(String columnName) {
this.columnName = columnName;
}
/**
* Name of that column's feature for the pipeline
*
* @return
* The featureName
*/
@JsonProperty("featureName")
public String getFeatureName() {
return featureName;
}
/**
* Name of that column's feature for the pipeline
*
* @param featureName
* The featureName
*/
@JsonProperty("featureName")
public void setFeatureName(String featureName) {
this.featureName = featureName;
}
/**
* Type of the feature
*
* @return
* The type
*/
@JsonProperty("type")
public String getType() {
return type;
}
/**
* Type of the feature
*
* @param type
* The type
*/
@JsonProperty("type")
public void setType(String type) {
this.type = type;
}
@Override
public String toString() {
return ToStringBuilder.reflectionToString(this);
}
@JsonAnyGetter
public Map<String, Object> getAdditionalProperties() {
return this.additionalProperties;
}
@JsonAnySetter
public void setAdditionalProperty(String name, Object value) {
this.additionalProperties.put(name, value);
}
@Override
public int hashCode() {
return new HashCodeBuilder().append(columnName).append(featureName).append(type).append(additionalProperties).toHashCode();
}
@Override
public boolean equals(Object other) {
if (other == this) {
return true;
}
if ((other instanceof Feature) == false) {
return false;
}
Feature rhs = ((Feature) other);
return new EqualsBuilder().append(columnName, rhs.columnName).append(featureName, rhs.featureName).append(type, rhs.type).append(additionalProperties, rhs.additionalProperties).isEquals();
}
}
Spark アプリケーションでスキーマから生成された POJO クラスの 1 つを使用しています。このクラスは、分散設定で使用できるように Serializable を実装する必要があります。
次のようにシリアライゼーションを実装するには、結果のクラスが必要です。
public class Feature implements Serializable {
}
POJO クラスに Serializable を実装する方法を知っている人はいますか? シリアライズ可能にするJSONスキーマ設定ですか？
私は運が悪いので、グーグル全体を見てきました。前もって感謝します。