Encoders
Apache Spark でコレクション タイプを作成する方法はありますか。以下のアプローチを試しましたが、うまくいきません。
import java.io.Serializable;
public class CollectionEntity<T> implements Serializable {
private T collectionData;
public T getCollectionData(){
return collectionData;
}
public void setCollectionData(T inputCollectionData){
this.collectionData = inputCollectionData;
}
}
次に、子クラスを作成しました
public class CollectionEntityForStringArray extends CollectionEntity<String[]> {
}
しかし、以下のようにエンコーダーを作成しようとすると、コンパイルエラーが表示されます
Encoder<CollectionEntity<String[]>> collectionEncoder = Encoders.bean(CollectionEntityForStringArray.class);
互換性のないタイプ。Encoder> が必要ですが、bean は Encode に推論されました。互換性のない等価制約です。