有没有办法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 被推断为编码。不兼容的等式约束。