1

EncodersApache 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 に推論されました。互換性のない等価制約です。

4

0 に答える 0