1

有没有办法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);

不兼容的类型。必需的编码器>,但 bean 被推断为编码。不兼容的等式约束。

4

0 回答 0